zt/common/pb/edge_ctrl_pb/messages.go

package edge_ctrl_pb

import (
	"github.com/hanzozt/edge-api/rest_model"
	"github.com/hanzozt/sdk-golang/zt"
	"github.com/hanzozt/zt/v2/controller/xt"
)

func (m *ClientHello) GetContentType() int32 {
	return int32(ContentType_ClientHelloType)
}

func (m *ServerHello) GetContentType() int32 {
	return int32(ContentType_ServerHelloType)
}

func (m *RequestClientReSync) GetContentType() int32 {
	return int32(ContentType_RequestClientReSyncType)
}

func (m *CreateCircuitRequest) GetContentType() int32 {
	return int32(ContentType_CreateCircuitRequestType)
}

func (m *CreateCircuitResponse) GetContentType() int32 {
	return int32(ContentType_CreateCircuitResponseType)
}

func (request *CreateTerminatorV2Request) GetContentType() int32 {
	return int32(ContentType_CreateTerminatorV2RequestType)
}

func (request *CreateTerminatorV2Request) GetXtPrecedence() xt.Precedence {
	if request.GetPrecedence() == TerminatorPrecedence_Failed {
		return xt.Precedences.Failed
	}
	if request.GetPrecedence() == TerminatorPrecedence_Required {
		return xt.Precedences.Required
	}
	return xt.Precedences.Default
}

func (request *CreateTerminatorV2Response) GetContentType() int32 {
	return int32(ContentType_CreateTerminatorV2ResponseType)
}

func (request *Error) GetContentType() int32 {
	return int32(ContentType_ErrorType)
}

func (request *UpdateTerminatorRequest) GetContentType() int32 {
	return int32(ContentType_UpdateTerminatorRequestType)
}

func (request *RemoveTerminatorRequest) GetContentType() int32 {
	return int32(ContentType_RemoveTerminatorRequestType)
}

func (request *ValidateSessionsRequest) GetContentType() int32 {
	return int32(ContentType_ValidateSessionsRequestType)
}

func (request *HealthEventRequest) GetContentType() int32 {
	return int32(ContentType_HealthEventType)
}

func (request *CreateApiSessionRequest) GetContentType() int32 {
	return int32(ContentType_CreateApiSessionRequestType)
}

func (request *CreateApiSessionResponse) GetContentType() int32 {
	return int32(ContentType_CreateApiSessionResponseType)
}

func (m *CreateCircuitForServiceRequest) GetContentType() int32 {
	return int32(ContentType_CreateCircuitForServiceRequestType)
}

func (m *CreateCircuitForServiceResponse) GetContentType() int32 {
	return int32(ContentType_CreateCircuitForServiceResponseType)
}

func (m *CreateTunnelCircuitV2Request) GetContentType() int32 {
	return int32(ContentType_CreateTunnelCircuitV2RequestType)
}

func (m *CreateTunnelCircuitV2Response) GetContentType() int32 {
	return int32(ContentType_CreateTunnelCircuitV2ResponseType)
}

func (m *ServicesList) GetContentType() int32 {
	return int32(ContentType_ServiceListType)
}

func (request *CreateTunnelTerminatorRequest) GetContentType() int32 {
	return int32(ContentType_CreateTunnelTerminatorRequestType)
}

func (request *CreateTunnelTerminatorRequestV2) GetContentType() int32 {
	return int32(ContentType_CreateTunnelTerminatorRequestV2Type)
}

func (request *CreateTunnelTerminatorRequestV2) GetXtPrecedence() xt.Precedence {
	if request.GetPrecedence() == TerminatorPrecedence_Failed {
		return xt.Precedences.Failed
	}
	if request.GetPrecedence() == TerminatorPrecedence_Required {
		return xt.Precedences.Required
	}
	return xt.Precedences.Default
}

func (request *EnrollmentExtendRouterVerifyRequest) GetContentType() int32 {
	return int32(ContentType_EnrollmentExtendRouterVerifyRequestType)
}

func (request *CreateTunnelTerminatorRequest) GetXtPrecedence() xt.Precedence {
	if request.GetPrecedence() == TerminatorPrecedence_Failed {
		return xt.Precedences.Failed
	}
	if request.GetPrecedence() == TerminatorPrecedence_Required {
		return xt.Precedences.Required
	}
	return xt.Precedences.Default
}

func (request *CreateTunnelTerminatorResponse) GetContentType() int32 {
	return int32(ContentType_CreateTunnelTerminatorResponseType)
}

func (request *CreateTunnelTerminatorResponseV2) GetContentType() int32 {
	return int32(ContentType_CreateTunnelTerminatorResponseV2Type)
}

func (request *UpdateTunnelTerminatorRequest) GetContentType() int32 {
	return int32(ContentType_UpdateTunnelTerminatorRequestType)
}

func (request *ConnectEvents) GetContentType() int32 {
	return int32(ContentType_ConnectEventsTypes)
}

func (request *DataState_ChangeSet) GetContentType() int32 {
	return int32(ContentType_DataStateChangeSetType)
}

func (request *DataState) GetContentType() int32 {
	return int32(ContentType_DataStateType)
}

func (request *SubscribeToDataModelRequest) GetContentType() int32 {
	return int32(ContentType_SubscribeToDataModelRequestType)
}

func GetPrecedence(p zt.Precedence) TerminatorPrecedence {
	if p == zt.PrecedenceRequired {
		return TerminatorPrecedence_Required
	}
	if p == zt.PrecedenceFailed {
		return TerminatorPrecedence_Failed
	}
	return TerminatorPrecedence_Default
}

func (self TerminatorPrecedence) GetZitiLabel() rest_model.TerminatorPrecedence {
	if self == TerminatorPrecedence_Default {
		return rest_model.TerminatorPrecedenceDefault
	}

	if self == TerminatorPrecedence_Required {
		return rest_model.TerminatorPrecedenceRequired
	}

	if self == TerminatorPrecedence_Failed {
		return rest_model.TerminatorPrecedenceFailed
	}

	return rest_model.TerminatorPrecedenceDefault
}