gsadmin/ziti
1
0
Fork 0
mirror of https://github.com/openziti/ziti.git synced 2026-09-11 01:05:42 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
main
ziti/common/pb/ctrl_pb/ctrl.pb.go
T
Paul Lorenz 48e4d4a224 Manage router link configuration via the controller. Fixes #4004 
- adds a link ConfigHandler (router/link FactoryRegistry) that applies router.link.v1 config: Apply rebuilds the listener/dialer set wholesale, and established Xlinks survive because Listener.Close() only closes the accept loop
- translates local link: YAML into router.link.v1 JSON and pushes it through the managed-config registry at startup
- adds the UpdateLinkListeners ctrl message so the router republishes its listener set to the controller on change; the controller re-fans via the existing PeerStateChange path
- re-evaluates dialers on link group and listener changes via RescanForDialOpportunities

For #3743.
2026-08-13 15:37:24 -04:00

3452 lines
102 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.11
// protoc v3.21.12
// source: ctrl.proto
package ctrl_pb
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// ContentTypes should be in the range 1000 - 1999, to ensure they don't overlap with cmd_pb messages
type ContentType int32
const (
ContentType_Zero ContentType = 0
ContentType_CircuitRequestType ContentType = 1000
ContentType_FaultType ContentType = 1004
ContentType_RouteType ContentType = 1005
ContentType_UnrouteType ContentType = 1006
ContentType_MetricsType ContentType = 1007
ContentType_TogglePipeTracesRequestType ContentType = 1008
ContentType_TraceEventType ContentType = 1010
ContentType_CreateTerminatorRequestType ContentType = 1011
ContentType_RemoveTerminatorRequestType ContentType = 1012
ContentType_InspectRequestType ContentType = 1013
ContentType_InspectResponseType ContentType = 1014
// defined in ctrl_msg/messages.go now
// CircuitFailedType = 1016;
ContentType_ValidateTerminatorsRequestType ContentType = 1017
ContentType_UpdateTerminatorRequestType ContentType = 1018
// VerifyLinkType = 1019; Unusable since links are now generated by routers
ContentType_SettingsType ContentType = 1020
ContentType_CircuitConfirmationType ContentType = 1034
ContentType_RouterLinksType ContentType = 1035
ContentType_VerifyRouterType ContentType = 1036
ContentType_UpdateCtrlAddressesType ContentType = 1037
ContentType_RemoveTerminatorsRequestType ContentType = 1038
ContentType_QuiesceRouterRequestType ContentType = 1039
ContentType_DequiesceRouterRequestType ContentType = 1040
ContentType_ValidateTerminatorsV2RequestType ContentType = 1041
ContentType_ValidateTerminatorsV2ResponseType ContentType = 1042
ContentType_DecommissionRouterRequestType ContentType = 1043
ContentType_PeerStateChangeRequestType ContentType = 1050
ContentType_UpdateClusterLeaderRequestType ContentType = 1051
ContentType_UpdateRouterInterfaces ContentType = 1052
ContentType_LinkState ContentType = 1053
ContentType_AlertsType ContentType = 1054
ContentType_RequestClusterMembers ContentType = 1055
ContentType_UpdateLinkListenersType ContentType = 1056
)
// Enum value maps for ContentType.
var (
ContentType_name = map[int32]string{
0: "Zero",
1000: "CircuitRequestType",
1004: "FaultType",
1005: "RouteType",
1006: "UnrouteType",
1007: "MetricsType",
1008: "TogglePipeTracesRequestType",
1010: "TraceEventType",
1011: "CreateTerminatorRequestType",
1012: "RemoveTerminatorRequestType",
1013: "InspectRequestType",
1014: "InspectResponseType",
1017: "ValidateTerminatorsRequestType",
1018: "UpdateTerminatorRequestType",
1020: "SettingsType",
1034: "CircuitConfirmationType",
1035: "RouterLinksType",
1036: "VerifyRouterType",
1037: "UpdateCtrlAddressesType",
1038: "RemoveTerminatorsRequestType",
1039: "QuiesceRouterRequestType",
1040: "DequiesceRouterRequestType",
1041: "ValidateTerminatorsV2RequestType",
1042: "ValidateTerminatorsV2ResponseType",
1043: "DecommissionRouterRequestType",
1050: "PeerStateChangeRequestType",
1051: "UpdateClusterLeaderRequestType",
1052: "UpdateRouterInterfaces",
1053: "LinkState",
1054: "AlertsType",
1055: "RequestClusterMembers",
1056: "UpdateLinkListenersType",
}
ContentType_value = map[string]int32{
"Zero": 0,
"CircuitRequestType": 1000,
"FaultType": 1004,
"RouteType": 1005,
"UnrouteType": 1006,
"MetricsType": 1007,
"TogglePipeTracesRequestType": 1008,
"TraceEventType": 1010,
"CreateTerminatorRequestType": 1011,
"RemoveTerminatorRequestType": 1012,
"InspectRequestType": 1013,
"InspectResponseType": 1014,
"ValidateTerminatorsRequestType": 1017,
"UpdateTerminatorRequestType": 1018,
"SettingsType": 1020,
"CircuitConfirmationType": 1034,
"RouterLinksType": 1035,
"VerifyRouterType": 1036,
"UpdateCtrlAddressesType": 1037,
"RemoveTerminatorsRequestType": 1038,
"QuiesceRouterRequestType": 1039,
"DequiesceRouterRequestType": 1040,
"ValidateTerminatorsV2RequestType": 1041,
"ValidateTerminatorsV2ResponseType": 1042,
"DecommissionRouterRequestType": 1043,
"PeerStateChangeRequestType": 1050,
"UpdateClusterLeaderRequestType": 1051,
"UpdateRouterInterfaces": 1052,
"LinkState": 1053,
"AlertsType": 1054,
"RequestClusterMembers": 1055,
"UpdateLinkListenersType": 1056,
}
)
func (x ContentType) Enum() *ContentType {
p := new(ContentType)
*p = x
return p
}
func (x ContentType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ContentType) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[0].Descriptor()
}
func (ContentType) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[0]
}
func (x ContentType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ContentType.Descriptor instead.
func (ContentType) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{0}
}
type ControlHeaders int32
const (
ControlHeaders_NoneHeader ControlHeaders = 0
ControlHeaders_ListenersHeader ControlHeaders = 1000
ControlHeaders_RouterMetadataHeader ControlHeaders = 1001
ControlHeaders_CapabilitiesHeader ControlHeaders = 1002
ControlHeaders_CtrlChanListenersHeader ControlHeaders = 1003
)
// Enum value maps for ControlHeaders.
var (
ControlHeaders_name = map[int32]string{
0: "NoneHeader",
1000: "ListenersHeader",
1001: "RouterMetadataHeader",
1002: "CapabilitiesHeader",
1003: "CtrlChanListenersHeader",
}
ControlHeaders_value = map[string]int32{
"NoneHeader": 0,
"ListenersHeader": 1000,
"RouterMetadataHeader": 1001,
"CapabilitiesHeader": 1002,
"CtrlChanListenersHeader": 1003,
}
)
func (x ControlHeaders) Enum() *ControlHeaders {
p := new(ControlHeaders)
*p = x
return p
}
func (x ControlHeaders) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ControlHeaders) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[1].Descriptor()
}
func (ControlHeaders) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[1]
}
func (x ControlHeaders) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ControlHeaders.Descriptor instead.
func (ControlHeaders) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{1}
}
type RouterCapability int32
const (
RouterCapability_CapabilityZero RouterCapability = 0
RouterCapability_LinkManagement RouterCapability = 1
)
// Enum value maps for RouterCapability.
var (
RouterCapability_name = map[int32]string{
0: "CapabilityZero",
1: "LinkManagement",
}
RouterCapability_value = map[string]int32{
"CapabilityZero": 0,
"LinkManagement": 1,
}
)
func (x RouterCapability) Enum() *RouterCapability {
p := new(RouterCapability)
*p = x
return p
}
func (x RouterCapability) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (RouterCapability) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[2].Descriptor()
}
func (RouterCapability) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[2]
}
func (x RouterCapability) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use RouterCapability.Descriptor instead.
func (RouterCapability) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{2}
}
// SettingTypes are used with the Settings message send arbitrary settings to routers.
// SettingTypes default to int32 which can be used seamlessly for keys in the Settings.data field
type SettingTypes int32
const (
// unused, consume to avoid zero value accidents
SettingTypes_UnusedSetting SettingTypes = 0
// Sent to routers to notify them of a controller IP/hostname move
SettingTypes_NewCtrlAddress SettingTypes = 1
)
// Enum value maps for SettingTypes.
var (
SettingTypes_name = map[int32]string{
0: "UnusedSetting",
1: "NewCtrlAddress",
}
SettingTypes_value = map[string]int32{
"UnusedSetting": 0,
"NewCtrlAddress": 1,
}
)
func (x SettingTypes) Enum() *SettingTypes {
p := new(SettingTypes)
*p = x
return p
}
func (x SettingTypes) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (SettingTypes) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[3].Descriptor()
}
func (SettingTypes) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[3]
}
func (x SettingTypes) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use SettingTypes.Descriptor instead.
func (SettingTypes) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{3}
}
type TerminatorPrecedence int32
const (
TerminatorPrecedence_Default TerminatorPrecedence = 0
TerminatorPrecedence_Required TerminatorPrecedence = 1
TerminatorPrecedence_Failed TerminatorPrecedence = 2
)
// Enum value maps for TerminatorPrecedence.
var (
TerminatorPrecedence_name = map[int32]string{
0: "Default",
1: "Required",
2: "Failed",
}
TerminatorPrecedence_value = map[string]int32{
"Default": 0,
"Required": 1,
"Failed": 2,
}
)
func (x TerminatorPrecedence) Enum() *TerminatorPrecedence {
p := new(TerminatorPrecedence)
*p = x
return p
}
func (x TerminatorPrecedence) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (TerminatorPrecedence) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[4].Descriptor()
}
func (TerminatorPrecedence) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[4]
}
func (x TerminatorPrecedence) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use TerminatorPrecedence.Descriptor instead.
func (TerminatorPrecedence) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{4}
}
type TerminatorInvalidReason int32
const (
TerminatorInvalidReason_UnknownBinding TerminatorInvalidReason = 0
TerminatorInvalidReason_UnknownTerminator TerminatorInvalidReason = 1
TerminatorInvalidReason_BadState TerminatorInvalidReason = 2
)
// Enum value maps for TerminatorInvalidReason.
var (
TerminatorInvalidReason_name = map[int32]string{
0: "UnknownBinding",
1: "UnknownTerminator",
2: "BadState",
}
TerminatorInvalidReason_value = map[string]int32{
"UnknownBinding": 0,
"UnknownTerminator": 1,
"BadState": 2,
}
)
func (x TerminatorInvalidReason) Enum() *TerminatorInvalidReason {
p := new(TerminatorInvalidReason)
*p = x
return p
}
func (x TerminatorInvalidReason) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (TerminatorInvalidReason) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[5].Descriptor()
}
func (TerminatorInvalidReason) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[5]
}
func (x TerminatorInvalidReason) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use TerminatorInvalidReason.Descriptor instead.
func (TerminatorInvalidReason) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{5}
}
type FaultSubject int32
const (
FaultSubject_IngressFault FaultSubject = 0
FaultSubject_EgressFault FaultSubject = 1
FaultSubject_LinkFault FaultSubject = 2
FaultSubject_ForwardFault FaultSubject = 3
FaultSubject_UnknownOwnerForwardFault FaultSubject = 4
FaultSubject_LinkDuplicate FaultSubject = 5
)
// Enum value maps for FaultSubject.
var (
FaultSubject_name = map[int32]string{
0: "IngressFault",
1: "EgressFault",
2: "LinkFault",
3: "ForwardFault",
4: "UnknownOwnerForwardFault",
5: "LinkDuplicate",
}
FaultSubject_value = map[string]int32{
"IngressFault": 0,
"EgressFault": 1,
"LinkFault": 2,
"ForwardFault": 3,
"UnknownOwnerForwardFault": 4,
"LinkDuplicate": 5,
}
)
func (x FaultSubject) Enum() *FaultSubject {
p := new(FaultSubject)
*p = x
return p
}
func (x FaultSubject) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (FaultSubject) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[6].Descriptor()
}
func (FaultSubject) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[6]
}
func (x FaultSubject) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use FaultSubject.Descriptor instead.
func (FaultSubject) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{6}
}
type DestType int32
const (
DestType_Start DestType = 0
DestType_End DestType = 1
DestType_Link DestType = 2
)
// Enum value maps for DestType.
var (
DestType_name = map[int32]string{
0: "Start",
1: "End",
2: "Link",
}
DestType_value = map[string]int32{
"Start": 0,
"End": 1,
"Link": 2,
}
)
func (x DestType) Enum() *DestType {
p := new(DestType)
*p = x
return p
}
func (x DestType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (DestType) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[7].Descriptor()
}
func (DestType) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[7]
}
func (x DestType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use DestType.Descriptor instead.
func (DestType) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{7}
}
type PeerState int32
const (
PeerState_Healthy PeerState = 0
PeerState_Unhealthy PeerState = 1
PeerState_Removed PeerState = 2
)
// Enum value maps for PeerState.
var (
PeerState_name = map[int32]string{
0: "Healthy",
1: "Unhealthy",
2: "Removed",
}
PeerState_value = map[string]int32{
"Healthy": 0,
"Unhealthy": 1,
"Removed": 2,
}
)
func (x PeerState) Enum() *PeerState {
p := new(PeerState)
*p = x
return p
}
func (x PeerState) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (PeerState) Descriptor() protoreflect.EnumDescriptor {
return file_ctrl_proto_enumTypes[8].Descriptor()
}
func (PeerState) Type() protoreflect.EnumType {
return &file_ctrl_proto_enumTypes[8]
}
func (x PeerState) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use PeerState.Descriptor instead.
func (PeerState) EnumDescriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{8}
}
// Settings are sent to to routers to configure arbitrary runtime settings.
type Settings struct {
state protoimpl.MessageState `protogen:"open.v1"`
Data map[int32][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Settings) Reset() {
*x = Settings{}
mi := &file_ctrl_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Settings) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Settings) ProtoMessage() {}
func (x *Settings) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Settings.ProtoReflect.Descriptor instead.
func (*Settings) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{0}
}
func (x *Settings) GetData() map[int32][]byte {
if x != nil {
return x.Data
}
return nil
}
type CircuitRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
IngressId string `protobuf:"bytes,1,opt,name=ingressId,proto3" json:"ingressId,omitempty"`
Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
PeerData map[uint32][]byte `protobuf:"bytes,3,rep,name=peerData,proto3" json:"peerData,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CircuitRequest) Reset() {
*x = CircuitRequest{}
mi := &file_ctrl_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CircuitRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CircuitRequest) ProtoMessage() {}
func (x *CircuitRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CircuitRequest.ProtoReflect.Descriptor instead.
func (*CircuitRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{1}
}
func (x *CircuitRequest) GetIngressId() string {
if x != nil {
return x.IngressId
}
return ""
}
func (x *CircuitRequest) GetService() string {
if x != nil {
return x.Service
}
return ""
}
func (x *CircuitRequest) GetPeerData() map[uint32][]byte {
if x != nil {
return x.PeerData
}
return nil
}
type CircuitConfirmation struct {
state protoimpl.MessageState `protogen:"open.v1"`
CircuitIds []string `protobuf:"bytes,1,rep,name=circuitIds,proto3" json:"circuitIds,omitempty"`
IdleTimes map[string]int64 `protobuf:"bytes,2,rep,name=idleTimes,proto3" json:"idleTimes,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CircuitConfirmation) Reset() {
*x = CircuitConfirmation{}
mi := &file_ctrl_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CircuitConfirmation) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CircuitConfirmation) ProtoMessage() {}
func (x *CircuitConfirmation) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CircuitConfirmation.ProtoReflect.Descriptor instead.
func (*CircuitConfirmation) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{2}
}
func (x *CircuitConfirmation) GetCircuitIds() []string {
if x != nil {
return x.CircuitIds
}
return nil
}
func (x *CircuitConfirmation) GetIdleTimes() map[string]int64 {
if x != nil {
return x.IdleTimes
}
return nil
}
type CreateTerminatorRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
ServiceId string `protobuf:"bytes,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
Binding string `protobuf:"bytes,3,opt,name=binding,proto3" json:"binding,omitempty"`
Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
PeerData map[uint32][]byte `protobuf:"bytes,5,rep,name=peerData,proto3" json:"peerData,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
Cost uint32 `protobuf:"varint,6,opt,name=cost,proto3" json:"cost,omitempty"`
Precedence TerminatorPrecedence `protobuf:"varint,7,opt,name=precedence,proto3,enum=ziti.ctrl.pb.TerminatorPrecedence" json:"precedence,omitempty"`
InstanceId string `protobuf:"bytes,8,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
InstanceSecret []byte `protobuf:"bytes,9,opt,name=instanceSecret,proto3" json:"instanceSecret,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateTerminatorRequest) Reset() {
*x = CreateTerminatorRequest{}
mi := &file_ctrl_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateTerminatorRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateTerminatorRequest) ProtoMessage() {}
func (x *CreateTerminatorRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreateTerminatorRequest.ProtoReflect.Descriptor instead.
func (*CreateTerminatorRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{3}
}
func (x *CreateTerminatorRequest) GetServiceId() string {
if x != nil {
return x.ServiceId
}
return ""
}
func (x *CreateTerminatorRequest) GetBinding() string {
if x != nil {
return x.Binding
}
return ""
}
func (x *CreateTerminatorRequest) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *CreateTerminatorRequest) GetPeerData() map[uint32][]byte {
if x != nil {
return x.PeerData
}
return nil
}
func (x *CreateTerminatorRequest) GetCost() uint32 {
if x != nil {
return x.Cost
}
return 0
}
func (x *CreateTerminatorRequest) GetPrecedence() TerminatorPrecedence {
if x != nil {
return x.Precedence
}
return TerminatorPrecedence_Default
}
func (x *CreateTerminatorRequest) GetInstanceId() string {
if x != nil {
return x.InstanceId
}
return ""
}
func (x *CreateTerminatorRequest) GetInstanceSecret() []byte {
if x != nil {
return x.InstanceSecret
}
return nil
}
type RemoveTerminatorRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
TerminatorId string `protobuf:"bytes,1,opt,name=terminatorId,proto3" json:"terminatorId,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RemoveTerminatorRequest) Reset() {
*x = RemoveTerminatorRequest{}
mi := &file_ctrl_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RemoveTerminatorRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RemoveTerminatorRequest) ProtoMessage() {}
func (x *RemoveTerminatorRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RemoveTerminatorRequest.ProtoReflect.Descriptor instead.
func (*RemoveTerminatorRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{4}
}
func (x *RemoveTerminatorRequest) GetTerminatorId() string {
if x != nil {
return x.TerminatorId
}
return ""
}
type RemoveTerminatorsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
TerminatorIds []string `protobuf:"bytes,1,rep,name=terminatorIds,proto3" json:"terminatorIds,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RemoveTerminatorsRequest) Reset() {
*x = RemoveTerminatorsRequest{}
mi := &file_ctrl_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RemoveTerminatorsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RemoveTerminatorsRequest) ProtoMessage() {}
func (x *RemoveTerminatorsRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RemoveTerminatorsRequest.ProtoReflect.Descriptor instead.
func (*RemoveTerminatorsRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{5}
}
func (x *RemoveTerminatorsRequest) GetTerminatorIds() []string {
if x != nil {
return x.TerminatorIds
}
return nil
}
type Terminator struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Binding string `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"`
Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
Marker uint64 `protobuf:"varint,4,opt,name=marker,proto3" json:"marker,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Terminator) Reset() {
*x = Terminator{}
mi := &file_ctrl_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Terminator) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Terminator) ProtoMessage() {}
func (x *Terminator) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Terminator.ProtoReflect.Descriptor instead.
func (*Terminator) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{6}
}
func (x *Terminator) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *Terminator) GetBinding() string {
if x != nil {
return x.Binding
}
return ""
}
func (x *Terminator) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *Terminator) GetMarker() uint64 {
if x != nil {
return x.Marker
}
return 0
}
type ValidateTerminatorsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Terminators []*Terminator `protobuf:"bytes,1,rep,name=terminators,proto3" json:"terminators,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ValidateTerminatorsRequest) Reset() {
*x = ValidateTerminatorsRequest{}
mi := &file_ctrl_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ValidateTerminatorsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ValidateTerminatorsRequest) ProtoMessage() {}
func (x *ValidateTerminatorsRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ValidateTerminatorsRequest.ProtoReflect.Descriptor instead.
func (*ValidateTerminatorsRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{7}
}
func (x *ValidateTerminatorsRequest) GetTerminators() []*Terminator {
if x != nil {
return x.Terminators
}
return nil
}
type ValidateTerminatorsV2Request struct {
state protoimpl.MessageState `protogen:"open.v1"`
Terminators []*Terminator `protobuf:"bytes,1,rep,name=terminators,proto3" json:"terminators,omitempty"`
FixInvalid bool `protobuf:"varint,2,opt,name=fixInvalid,proto3" json:"fixInvalid,omitempty"`
PostCreate bool `protobuf:"varint,3,opt,name=postCreate,proto3" json:"postCreate,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ValidateTerminatorsV2Request) Reset() {
*x = ValidateTerminatorsV2Request{}
mi := &file_ctrl_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ValidateTerminatorsV2Request) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ValidateTerminatorsV2Request) ProtoMessage() {}
func (x *ValidateTerminatorsV2Request) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ValidateTerminatorsV2Request.ProtoReflect.Descriptor instead.
func (*ValidateTerminatorsV2Request) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{8}
}
func (x *ValidateTerminatorsV2Request) GetTerminators() []*Terminator {
if x != nil {
return x.Terminators
}
return nil
}
func (x *ValidateTerminatorsV2Request) GetFixInvalid() bool {
if x != nil {
return x.FixInvalid
}
return false
}
func (x *ValidateTerminatorsV2Request) GetPostCreate() bool {
if x != nil {
return x.PostCreate
}
return false
}
type RouterTerminatorState struct {
state protoimpl.MessageState `protogen:"open.v1"`
Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
Reason TerminatorInvalidReason `protobuf:"varint,2,opt,name=reason,proto3,enum=ziti.ctrl.pb.TerminatorInvalidReason" json:"reason,omitempty"`
Detail string `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` // inspect info if valid
Marker uint64 `protobuf:"varint,4,opt,name=marker,proto3" json:"marker,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RouterTerminatorState) Reset() {
*x = RouterTerminatorState{}
mi := &file_ctrl_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RouterTerminatorState) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RouterTerminatorState) ProtoMessage() {}
func (x *RouterTerminatorState) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RouterTerminatorState.ProtoReflect.Descriptor instead.
func (*RouterTerminatorState) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{9}
}
func (x *RouterTerminatorState) GetValid() bool {
if x != nil {
return x.Valid
}
return false
}
func (x *RouterTerminatorState) GetReason() TerminatorInvalidReason {
if x != nil {
return x.Reason
}
return TerminatorInvalidReason_UnknownBinding
}
func (x *RouterTerminatorState) GetDetail() string {
if x != nil {
return x.Detail
}
return ""
}
func (x *RouterTerminatorState) GetMarker() uint64 {
if x != nil {
return x.Marker
}
return 0
}
type ValidateTerminatorsV2Response struct {
state protoimpl.MessageState `protogen:"open.v1"`
States map[string]*RouterTerminatorState `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ValidateTerminatorsV2Response) Reset() {
*x = ValidateTerminatorsV2Response{}
mi := &file_ctrl_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ValidateTerminatorsV2Response) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ValidateTerminatorsV2Response) ProtoMessage() {}
func (x *ValidateTerminatorsV2Response) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ValidateTerminatorsV2Response.ProtoReflect.Descriptor instead.
func (*ValidateTerminatorsV2Response) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{10}
}
func (x *ValidateTerminatorsV2Response) GetStates() map[string]*RouterTerminatorState {
if x != nil {
return x.States
}
return nil
}
type UpdateTerminatorRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
TerminatorId string `protobuf:"bytes,1,opt,name=terminatorId,proto3" json:"terminatorId,omitempty"`
UpdatePrecedence bool `protobuf:"varint,2,opt,name=updatePrecedence,proto3" json:"updatePrecedence,omitempty"`
UpdateCost bool `protobuf:"varint,3,opt,name=updateCost,proto3" json:"updateCost,omitempty"`
Precedence TerminatorPrecedence `protobuf:"varint,4,opt,name=precedence,proto3,enum=ziti.ctrl.pb.TerminatorPrecedence" json:"precedence,omitempty"`
Cost uint32 `protobuf:"varint,5,opt,name=cost,proto3" json:"cost,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UpdateTerminatorRequest) Reset() {
*x = UpdateTerminatorRequest{}
mi := &file_ctrl_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UpdateTerminatorRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UpdateTerminatorRequest) ProtoMessage() {}
func (x *UpdateTerminatorRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UpdateTerminatorRequest.ProtoReflect.Descriptor instead.
func (*UpdateTerminatorRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{11}
}
func (x *UpdateTerminatorRequest) GetTerminatorId() string {
if x != nil {
return x.TerminatorId
}
return ""
}
func (x *UpdateTerminatorRequest) GetUpdatePrecedence() bool {
if x != nil {
return x.UpdatePrecedence
}
return false
}
func (x *UpdateTerminatorRequest) GetUpdateCost() bool {
if x != nil {
return x.UpdateCost
}
return false
}
func (x *UpdateTerminatorRequest) GetPrecedence() TerminatorPrecedence {
if x != nil {
return x.Precedence
}
return TerminatorPrecedence_Default
}
func (x *UpdateTerminatorRequest) GetCost() uint32 {
if x != nil {
return x.Cost
}
return 0
}
type LinkConn struct {
state protoimpl.MessageState `protogen:"open.v1"`
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
LocalAddr string `protobuf:"bytes,2,opt,name=localAddr,proto3" json:"localAddr,omitempty"`
RemoteAddr string `protobuf:"bytes,3,opt,name=remoteAddr,proto3" json:"remoteAddr,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *LinkConn) Reset() {
*x = LinkConn{}
mi := &file_ctrl_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *LinkConn) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LinkConn) ProtoMessage() {}
func (x *LinkConn) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use LinkConn.ProtoReflect.Descriptor instead.
func (*LinkConn) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{12}
}
func (x *LinkConn) GetType() string {
if x != nil {
return x.Type
}
return ""
}
func (x *LinkConn) GetLocalAddr() string {
if x != nil {
return x.LocalAddr
}
return ""
}
func (x *LinkConn) GetRemoteAddr() string {
if x != nil {
return x.RemoteAddr
}
return ""
}
type LinkConnState struct {
state protoimpl.MessageState `protogen:"open.v1"`
StateIteration uint32 `protobuf:"varint,1,opt,name=stateIteration,proto3" json:"stateIteration,omitempty"`
Conns []*LinkConn `protobuf:"bytes,2,rep,name=conns,proto3" json:"conns,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *LinkConnState) Reset() {
*x = LinkConnState{}
mi := &file_ctrl_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *LinkConnState) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LinkConnState) ProtoMessage() {}
func (x *LinkConnState) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use LinkConnState.ProtoReflect.Descriptor instead.
func (*LinkConnState) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{13}
}
func (x *LinkConnState) GetStateIteration() uint32 {
if x != nil {
return x.StateIteration
}
return 0
}
func (x *LinkConnState) GetConns() []*LinkConn {
if x != nil {
return x.Conns
}
return nil
}
type RouterLinks struct {
state protoimpl.MessageState `protogen:"open.v1"`
Links []*RouterLinks_RouterLink `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
FullRefresh bool `protobuf:"varint,2,opt,name=fullRefresh,proto3" json:"fullRefresh,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RouterLinks) Reset() {
*x = RouterLinks{}
mi := &file_ctrl_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RouterLinks) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RouterLinks) ProtoMessage() {}
func (x *RouterLinks) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RouterLinks.ProtoReflect.Descriptor instead.
func (*RouterLinks) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{14}
}
func (x *RouterLinks) GetLinks() []*RouterLinks_RouterLink {
if x != nil {
return x.Links
}
return nil
}
func (x *RouterLinks) GetFullRefresh() bool {
if x != nil {
return x.FullRefresh
}
return false
}
type Fault struct {
state protoimpl.MessageState `protogen:"open.v1"`
Subject FaultSubject `protobuf:"varint,1,opt,name=subject,proto3,enum=ziti.ctrl.pb.FaultSubject" json:"subject,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Iteration uint32 `protobuf:"varint,3,opt,name=iteration,proto3" json:"iteration,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Fault) Reset() {
*x = Fault{}
mi := &file_ctrl_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Fault) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Fault) ProtoMessage() {}
func (x *Fault) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Fault.ProtoReflect.Descriptor instead.
func (*Fault) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{15}
}
func (x *Fault) GetSubject() FaultSubject {
if x != nil {
return x.Subject
}
return FaultSubject_IngressFault
}
func (x *Fault) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *Fault) GetIteration() uint32 {
if x != nil {
return x.Iteration
}
return 0
}
type Context struct {
state protoimpl.MessageState `protogen:"open.v1"`
Fields map[string]string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
ChannelMask uint32 `protobuf:"varint,2,opt,name=channelMask,proto3" json:"channelMask,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Context) Reset() {
*x = Context{}
mi := &file_ctrl_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Context) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Context) ProtoMessage() {}
func (x *Context) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Context.ProtoReflect.Descriptor instead.
func (*Context) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{16}
}
func (x *Context) GetFields() map[string]string {
if x != nil {
return x.Fields
}
return nil
}
func (x *Context) GetChannelMask() uint32 {
if x != nil {
return x.ChannelMask
}
return 0
}
type Route struct {
state protoimpl.MessageState `protogen:"open.v1"`
CircuitId string `protobuf:"bytes,1,opt,name=circuitId,proto3" json:"circuitId,omitempty"`
Attempt uint32 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
Egress *Route_Egress `protobuf:"bytes,3,opt,name=egress,proto3" json:"egress,omitempty"`
Forwards []*Route_Forward `protobuf:"bytes,4,rep,name=forwards,proto3" json:"forwards,omitempty"`
Context *Context `protobuf:"bytes,5,opt,name=context,proto3" json:"context,omitempty"`
Timeout uint64 `protobuf:"varint,6,opt,name=timeout,proto3" json:"timeout,omitempty"`
Tags map[string]string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Route) Reset() {
*x = Route{}
mi := &file_ctrl_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Route) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Route) ProtoMessage() {}
func (x *Route) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Route.ProtoReflect.Descriptor instead.
func (*Route) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{17}
}
func (x *Route) GetCircuitId() string {
if x != nil {
return x.CircuitId
}
return ""
}
func (x *Route) GetAttempt() uint32 {
if x != nil {
return x.Attempt
}
return 0
}
func (x *Route) GetEgress() *Route_Egress {
if x != nil {
return x.Egress
}
return nil
}
func (x *Route) GetForwards() []*Route_Forward {
if x != nil {
return x.Forwards
}
return nil
}
func (x *Route) GetContext() *Context {
if x != nil {
return x.Context
}
return nil
}
func (x *Route) GetTimeout() uint64 {
if x != nil {
return x.Timeout
}
return 0
}
func (x *Route) GetTags() map[string]string {
if x != nil {
return x.Tags
}
return nil
}
type Unroute struct {
state protoimpl.MessageState `protogen:"open.v1"`
CircuitId string `protobuf:"bytes,1,opt,name=circuitId,proto3" json:"circuitId,omitempty"`
Now bool `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Unroute) Reset() {
*x = Unroute{}
mi := &file_ctrl_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Unroute) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Unroute) ProtoMessage() {}
func (x *Unroute) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[18]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Unroute.ProtoReflect.Descriptor instead.
func (*Unroute) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{18}
}
func (x *Unroute) GetCircuitId() string {
if x != nil {
return x.CircuitId
}
return ""
}
func (x *Unroute) GetNow() bool {
if x != nil {
return x.Now
}
return false
}
type InspectRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
RequestedValues []string `protobuf:"bytes,1,rep,name=requestedValues,proto3" json:"requestedValues,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *InspectRequest) Reset() {
*x = InspectRequest{}
mi := &file_ctrl_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *InspectRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*InspectRequest) ProtoMessage() {}
func (x *InspectRequest) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[19]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use InspectRequest.ProtoReflect.Descriptor instead.
func (*InspectRequest) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{19}
}
func (x *InspectRequest) GetRequestedValues() []string {
if x != nil {
return x.RequestedValues
}
return nil
}
type InspectResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Errors []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
Values []*InspectResponse_InspectValue `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *InspectResponse) Reset() {
*x = InspectResponse{}
mi := &file_ctrl_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *InspectResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*InspectResponse) ProtoMessage() {}
func (x *InspectResponse) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[20]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use InspectResponse.ProtoReflect.Descriptor instead.
func (*InspectResponse) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{20}
}
func (x *InspectResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *InspectResponse) GetErrors() []string {
if x != nil {
return x.Errors
}
return nil
}
func (x *InspectResponse) GetValues() []*InspectResponse_InspectValue {
if x != nil {
return x.Values
}
return nil
}
type VerifyRouter struct {
state protoimpl.MessageState `protogen:"open.v1"`
RouterId string `protobuf:"bytes,1,opt,name=routerId,proto3" json:"routerId,omitempty"`
Fingerprints []string `protobuf:"bytes,2,rep,name=fingerprints,proto3" json:"fingerprints,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *VerifyRouter) Reset() {
*x = VerifyRouter{}
mi := &file_ctrl_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *VerifyRouter) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*VerifyRouter) ProtoMessage() {}
func (x *VerifyRouter) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[21]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use VerifyRouter.ProtoReflect.Descriptor instead.
func (*VerifyRouter) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{21}
}
func (x *VerifyRouter) GetRouterId() string {
if x != nil {
return x.RouterId
}
return ""
}
func (x *VerifyRouter) GetFingerprints() []string {
if x != nil {
return x.Fingerprints
}
return nil
}
type Listener struct {
state protoimpl.MessageState `protogen:"open.v1"`
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
Groups []string `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"`
LocalBinding string `protobuf:"bytes,5,opt,name=localBinding,proto3" json:"localBinding,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Listener) Reset() {
*x = Listener{}
mi := &file_ctrl_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Listener) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Listener) ProtoMessage() {}
func (x *Listener) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[22]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Listener.ProtoReflect.Descriptor instead.
func (*Listener) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{22}
}
func (x *Listener) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *Listener) GetProtocol() string {
if x != nil {
return x.Protocol
}
return ""
}
func (x *Listener) GetGroups() []string {
if x != nil {
return x.Groups
}
return nil
}
func (x *Listener) GetLocalBinding() string {
if x != nil {
return x.LocalBinding
}
return ""
}
type Listeners struct {
state protoimpl.MessageState `protogen:"open.v1"`
Listeners []*Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Listeners) Reset() {
*x = Listeners{}
mi := &file_ctrl_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Listeners) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Listeners) ProtoMessage() {}
func (x *Listeners) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[23]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Listeners.ProtoReflect.Descriptor instead.
func (*Listeners) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{23}
}
func (x *Listeners) GetListeners() []*Listener {
if x != nil {
return x.Listeners
}
return nil
}
type CtrlEndpoint struct {
state protoimpl.MessageState `protogen:"open.v1"`
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
Groups []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CtrlEndpoint) Reset() {
*x = CtrlEndpoint{}
mi := &file_ctrl_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CtrlEndpoint) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CtrlEndpoint) ProtoMessage() {}
func (x *CtrlEndpoint) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[24]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CtrlEndpoint.ProtoReflect.Descriptor instead.
func (*CtrlEndpoint) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{24}
}
func (x *CtrlEndpoint) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *CtrlEndpoint) GetGroups() []string {
if x != nil {
return x.Groups
}
return nil
}
type CtrlDetail struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Endpoints []*CtrlEndpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CtrlDetail) Reset() {
*x = CtrlDetail{}
mi := &file_ctrl_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CtrlDetail) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CtrlDetail) ProtoMessage() {}
func (x *CtrlDetail) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[25]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CtrlDetail.ProtoReflect.Descriptor instead.
func (*CtrlDetail) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{25}
}
func (x *CtrlDetail) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *CtrlDetail) GetEndpoints() []*CtrlEndpoint {
if x != nil {
return x.Endpoints
}
return nil
}
type UpdateCtrlAddresses struct {
state protoimpl.MessageState `protogen:"open.v1"`
Addresses []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
IsLeader bool `protobuf:"varint,3,opt,name=isLeader,proto3" json:"isLeader,omitempty"`
Controllers []*CtrlDetail `protobuf:"bytes,4,rep,name=controllers,proto3" json:"controllers,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UpdateCtrlAddresses) Reset() {
*x = UpdateCtrlAddresses{}
mi := &file_ctrl_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UpdateCtrlAddresses) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UpdateCtrlAddresses) ProtoMessage() {}
func (x *UpdateCtrlAddresses) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[26]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UpdateCtrlAddresses.ProtoReflect.Descriptor instead.
func (*UpdateCtrlAddresses) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{26}
}
func (x *UpdateCtrlAddresses) GetAddresses() []string {
if x != nil {
return x.Addresses
}
return nil
}
func (x *UpdateCtrlAddresses) GetIndex() uint64 {
if x != nil {
return x.Index
}
return 0
}
func (x *UpdateCtrlAddresses) GetIsLeader() bool {
if x != nil {
return x.IsLeader
}
return false
}
func (x *UpdateCtrlAddresses) GetControllers() []*CtrlDetail {
if x != nil {
return x.Controllers
}
return nil
}
type UpdateClusterLeader struct {
state protoimpl.MessageState `protogen:"open.v1"`
Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UpdateClusterLeader) Reset() {
*x = UpdateClusterLeader{}
mi := &file_ctrl_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UpdateClusterLeader) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UpdateClusterLeader) ProtoMessage() {}
func (x *UpdateClusterLeader) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[27]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UpdateClusterLeader.ProtoReflect.Descriptor instead.
func (*UpdateClusterLeader) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{27}
}
func (x *UpdateClusterLeader) GetIndex() uint64 {
if x != nil {
return x.Index
}
return 0
}
type PeerStateChange struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
State PeerState `protobuf:"varint,3,opt,name=state,proto3,enum=ziti.ctrl.pb.PeerState" json:"state,omitempty"`
Listeners []*Listener `protobuf:"bytes,4,rep,name=listeners,proto3" json:"listeners,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PeerStateChange) Reset() {
*x = PeerStateChange{}
mi := &file_ctrl_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PeerStateChange) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PeerStateChange) ProtoMessage() {}
func (x *PeerStateChange) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[28]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PeerStateChange.ProtoReflect.Descriptor instead.
func (*PeerStateChange) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{28}
}
func (x *PeerStateChange) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *PeerStateChange) GetVersion() string {
if x != nil {
return x.Version
}
return ""
}
func (x *PeerStateChange) GetState() PeerState {
if x != nil {
return x.State
}
return PeerState_Healthy
}
func (x *PeerStateChange) GetListeners() []*Listener {
if x != nil {
return x.Listeners
}
return nil
}
type PeerStateChanges struct {
state protoimpl.MessageState `protogen:"open.v1"`
Changes []*PeerStateChange `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PeerStateChanges) Reset() {
*x = PeerStateChanges{}
mi := &file_ctrl_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PeerStateChanges) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PeerStateChanges) ProtoMessage() {}
func (x *PeerStateChanges) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[29]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PeerStateChanges.ProtoReflect.Descriptor instead.
func (*PeerStateChanges) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{29}
}
func (x *PeerStateChanges) GetChanges() []*PeerStateChange {
if x != nil {
return x.Changes
}
return nil
}
type RouterMetadata struct {
state protoimpl.MessageState `protogen:"open.v1"`
Capabilities []RouterCapability `protobuf:"varint,1,rep,packed,name=capabilities,proto3,enum=ziti.ctrl.pb.RouterCapability" json:"capabilities,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RouterMetadata) Reset() {
*x = RouterMetadata{}
mi := &file_ctrl_proto_msgTypes[30]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RouterMetadata) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RouterMetadata) ProtoMessage() {}
func (x *RouterMetadata) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[30]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RouterMetadata.ProtoReflect.Descriptor instead.
func (*RouterMetadata) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{30}
}
func (x *RouterMetadata) GetCapabilities() []RouterCapability {
if x != nil {
return x.Capabilities
}
return nil
}
type Interface struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
HardwareAddress string `protobuf:"bytes,2,opt,name=hardwareAddress,proto3" json:"hardwareAddress,omitempty"`
Mtu int64 `protobuf:"varint,3,opt,name=mtu,proto3" json:"mtu,omitempty"`
Index int64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
Flags uint64 `protobuf:"varint,5,opt,name=flags,proto3" json:"flags,omitempty"`
Addresses []string `protobuf:"bytes,6,rep,name=addresses,proto3" json:"addresses,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Interface) Reset() {
*x = Interface{}
mi := &file_ctrl_proto_msgTypes[31]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Interface) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Interface) ProtoMessage() {}
func (x *Interface) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[31]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Interface.ProtoReflect.Descriptor instead.
func (*Interface) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{31}
}
func (x *Interface) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *Interface) GetHardwareAddress() string {
if x != nil {
return x.HardwareAddress
}
return ""
}
func (x *Interface) GetMtu() int64 {
if x != nil {
return x.Mtu
}
return 0
}
func (x *Interface) GetIndex() int64 {
if x != nil {
return x.Index
}
return 0
}
func (x *Interface) GetFlags() uint64 {
if x != nil {
return x.Flags
}
return 0
}
func (x *Interface) GetAddresses() []string {
if x != nil {
return x.Addresses
}
return nil
}
type RouterInterfacesUpdate struct {
state protoimpl.MessageState `protogen:"open.v1"`
Interfaces []*Interface `protobuf:"bytes,1,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RouterInterfacesUpdate) Reset() {
*x = RouterInterfacesUpdate{}
mi := &file_ctrl_proto_msgTypes[32]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RouterInterfacesUpdate) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RouterInterfacesUpdate) ProtoMessage() {}
func (x *RouterInterfacesUpdate) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[32]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RouterInterfacesUpdate.ProtoReflect.Descriptor instead.
func (*RouterInterfacesUpdate) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{32}
}
func (x *RouterInterfacesUpdate) GetInterfaces() []*Interface {
if x != nil {
return x.Interfaces
}
return nil
}
type LinkStateUpdate struct {
state protoimpl.MessageState `protogen:"open.v1"`
LinkId string `protobuf:"bytes,1,opt,name=linkId,proto3" json:"linkId,omitempty"`
LinkIteration uint32 `protobuf:"varint,2,opt,name=linkIteration,proto3" json:"linkIteration,omitempty"`
ConnState *LinkConnState `protobuf:"bytes,3,opt,name=connState,proto3" json:"connState,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *LinkStateUpdate) Reset() {
*x = LinkStateUpdate{}
mi := &file_ctrl_proto_msgTypes[33]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *LinkStateUpdate) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LinkStateUpdate) ProtoMessage() {}
func (x *LinkStateUpdate) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[33]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use LinkStateUpdate.ProtoReflect.Descriptor instead.
func (*LinkStateUpdate) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{33}
}
func (x *LinkStateUpdate) GetLinkId() string {
if x != nil {
return x.LinkId
}
return ""
}
func (x *LinkStateUpdate) GetLinkIteration() uint32 {
if x != nil {
return x.LinkIteration
}
return 0
}
func (x *LinkStateUpdate) GetConnState() *LinkConnState {
if x != nil {
return x.ConnState
}
return nil
}
type Alert struct {
state protoimpl.MessageState `protogen:"open.v1"`
SourceType string `protobuf:"bytes,1,opt,name=sourceType,proto3" json:"sourceType,omitempty"`
SourceId string `protobuf:"bytes,2,opt,name=sourceId,proto3" json:"sourceId,omitempty"`
Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Severity string `protobuf:"bytes,4,opt,name=severity,proto3" json:"severity,omitempty"`
Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
Details []string `protobuf:"bytes,6,rep,name=details,proto3" json:"details,omitempty"`
RelatedEntities map[string]string `protobuf:"bytes,7,rep,name=relatedEntities,proto3" json:"relatedEntities,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Alert) Reset() {
*x = Alert{}
mi := &file_ctrl_proto_msgTypes[34]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Alert) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Alert) ProtoMessage() {}
func (x *Alert) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[34]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Alert.ProtoReflect.Descriptor instead.
func (*Alert) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{34}
}
func (x *Alert) GetSourceType() string {
if x != nil {
return x.SourceType
}
return ""
}
func (x *Alert) GetSourceId() string {
if x != nil {
return x.SourceId
}
return ""
}
func (x *Alert) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *Alert) GetSeverity() string {
if x != nil {
return x.Severity
}
return ""
}
func (x *Alert) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *Alert) GetDetails() []string {
if x != nil {
return x.Details
}
return nil
}
func (x *Alert) GetRelatedEntities() map[string]string {
if x != nil {
return x.RelatedEntities
}
return nil
}
type Alerts struct {
state protoimpl.MessageState `protogen:"open.v1"`
Alerts []*Alert `protobuf:"bytes,1,rep,name=alerts,proto3" json:"alerts,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Alerts) Reset() {
*x = Alerts{}
mi := &file_ctrl_proto_msgTypes[35]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Alerts) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Alerts) ProtoMessage() {}
func (x *Alerts) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[35]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Alerts.ProtoReflect.Descriptor instead.
func (*Alerts) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{35}
}
func (x *Alerts) GetAlerts() []*Alert {
if x != nil {
return x.Alerts
}
return nil
}
type CtrlChanListener struct {
state protoimpl.MessageState `protogen:"open.v1"`
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
Groups []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CtrlChanListener) Reset() {
*x = CtrlChanListener{}
mi := &file_ctrl_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CtrlChanListener) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CtrlChanListener) ProtoMessage() {}
func (x *CtrlChanListener) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[36]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CtrlChanListener.ProtoReflect.Descriptor instead.
func (*CtrlChanListener) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{36}
}
func (x *CtrlChanListener) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *CtrlChanListener) GetGroups() []string {
if x != nil {
return x.Groups
}
return nil
}
type CtrlChanListeners struct {
state protoimpl.MessageState `protogen:"open.v1"`
Listeners []*CtrlChanListener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CtrlChanListeners) Reset() {
*x = CtrlChanListeners{}
mi := &file_ctrl_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CtrlChanListeners) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CtrlChanListeners) ProtoMessage() {}
func (x *CtrlChanListeners) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CtrlChanListeners.ProtoReflect.Descriptor instead.
func (*CtrlChanListeners) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{37}
}
func (x *CtrlChanListeners) GetListeners() []*CtrlChanListener {
if x != nil {
return x.Listeners
}
return nil
}
type RouterLinks_RouterLink struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
DestRouterId string `protobuf:"bytes,2,opt,name=destRouterId,proto3" json:"destRouterId,omitempty"`
LinkProtocol string `protobuf:"bytes,3,opt,name=linkProtocol,proto3" json:"linkProtocol,omitempty"`
DialAddress string `protobuf:"bytes,5,opt,name=dialAddress,proto3" json:"dialAddress,omitempty"`
Iteration uint32 `protobuf:"varint,6,opt,name=iteration,proto3" json:"iteration,omitempty"`
ConnState *LinkConnState `protobuf:"bytes,7,opt,name=connState,proto3" json:"connState,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RouterLinks_RouterLink) Reset() {
*x = RouterLinks_RouterLink{}
mi := &file_ctrl_proto_msgTypes[43]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RouterLinks_RouterLink) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RouterLinks_RouterLink) ProtoMessage() {}
func (x *RouterLinks_RouterLink) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[43]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RouterLinks_RouterLink.ProtoReflect.Descriptor instead.
func (*RouterLinks_RouterLink) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{14, 0}
}
func (x *RouterLinks_RouterLink) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *RouterLinks_RouterLink) GetDestRouterId() string {
if x != nil {
return x.DestRouterId
}
return ""
}
func (x *RouterLinks_RouterLink) GetLinkProtocol() string {
if x != nil {
return x.LinkProtocol
}
return ""
}
func (x *RouterLinks_RouterLink) GetDialAddress() string {
if x != nil {
return x.DialAddress
}
return ""
}
func (x *RouterLinks_RouterLink) GetIteration() uint32 {
if x != nil {
return x.Iteration
}
return 0
}
func (x *RouterLinks_RouterLink) GetConnState() *LinkConnState {
if x != nil {
return x.ConnState
}
return nil
}
type Route_Egress struct {
state protoimpl.MessageState `protogen:"open.v1"`
Binding string `protobuf:"bytes,1,opt,name=binding,proto3" json:"binding,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
PeerData map[uint32][]byte `protobuf:"bytes,4,rep,name=peerData,proto3" json:"peerData,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Route_Egress) Reset() {
*x = Route_Egress{}
mi := &file_ctrl_proto_msgTypes[45]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Route_Egress) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Route_Egress) ProtoMessage() {}
func (x *Route_Egress) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[45]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Route_Egress.ProtoReflect.Descriptor instead.
func (*Route_Egress) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{17, 0}
}
func (x *Route_Egress) GetBinding() string {
if x != nil {
return x.Binding
}
return ""
}
func (x *Route_Egress) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *Route_Egress) GetDestination() string {
if x != nil {
return x.Destination
}
return ""
}
func (x *Route_Egress) GetPeerData() map[uint32][]byte {
if x != nil {
return x.PeerData
}
return nil
}
type Route_Forward struct {
state protoimpl.MessageState `protogen:"open.v1"`
SrcAddress string `protobuf:"bytes,1,opt,name=srcAddress,proto3" json:"srcAddress,omitempty"`
DstAddress string `protobuf:"bytes,2,opt,name=dstAddress,proto3" json:"dstAddress,omitempty"`
DstType DestType `protobuf:"varint,3,opt,name=dstType,proto3,enum=ziti.ctrl.pb.DestType" json:"dstType,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Route_Forward) Reset() {
*x = Route_Forward{}
mi := &file_ctrl_proto_msgTypes[46]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Route_Forward) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Route_Forward) ProtoMessage() {}
func (x *Route_Forward) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[46]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Route_Forward.ProtoReflect.Descriptor instead.
func (*Route_Forward) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{17, 1}
}
func (x *Route_Forward) GetSrcAddress() string {
if x != nil {
return x.SrcAddress
}
return ""
}
func (x *Route_Forward) GetDstAddress() string {
if x != nil {
return x.DstAddress
}
return ""
}
func (x *Route_Forward) GetDstType() DestType {
if x != nil {
return x.DstType
}
return DestType_Start
}
type InspectResponse_InspectValue struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *InspectResponse_InspectValue) Reset() {
*x = InspectResponse_InspectValue{}
mi := &file_ctrl_proto_msgTypes[49]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *InspectResponse_InspectValue) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*InspectResponse_InspectValue) ProtoMessage() {}
func (x *InspectResponse_InspectValue) ProtoReflect() protoreflect.Message {
mi := &file_ctrl_proto_msgTypes[49]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use InspectResponse_InspectValue.ProtoReflect.Descriptor instead.
func (*InspectResponse_InspectValue) Descriptor() ([]byte, []int) {
return file_ctrl_proto_rawDescGZIP(), []int{20, 0}
}
func (x *InspectResponse_InspectValue) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *InspectResponse_InspectValue) GetValue() string {
if x != nil {
return x.Value
}
return ""
}
var File_ctrl_proto protoreflect.FileDescriptor
const file_ctrl_proto_rawDesc = "" +
"\n" +
"\n" +
"ctrl.proto\x12\fziti.ctrl.pb\"y\n" +
"\bSettings\x124\n" +
"\x04data\x18\x01 \x03(\v2 .ziti.ctrl.pb.Settings.DataEntryR\x04data\x1a7\n" +
"\tDataEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\x05R\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value:\x028\x01\"\xcd\x01\n" +
"\x0eCircuitRequest\x12\x1c\n" +
"\tingressId\x18\x01 \x01(\tR\tingressId\x12\x18\n" +
"\aservice\x18\x02 \x01(\tR\aservice\x12F\n" +
"\bpeerData\x18\x03 \x03(\v2*.ziti.ctrl.pb.CircuitRequest.PeerDataEntryR\bpeerData\x1a;\n" +
"\rPeerDataEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\rR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value:\x028\x01\"\xc3\x01\n" +
"\x13CircuitConfirmation\x12\x1e\n" +
"\n" +
"circuitIds\x18\x01 \x03(\tR\n" +
"circuitIds\x12N\n" +
"\tidleTimes\x18\x02 \x03(\v20.ziti.ctrl.pb.CircuitConfirmation.IdleTimesEntryR\tidleTimes\x1a<\n" +
"\x0eIdleTimesEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\x99\x03\n" +
"\x17CreateTerminatorRequest\x12\x1c\n" +
"\tserviceId\x18\x02 \x01(\tR\tserviceId\x12\x18\n" +
"\abinding\x18\x03 \x01(\tR\abinding\x12\x18\n" +
"\aaddress\x18\x04 \x01(\tR\aaddress\x12O\n" +
"\bpeerData\x18\x05 \x03(\v23.ziti.ctrl.pb.CreateTerminatorRequest.PeerDataEntryR\bpeerData\x12\x12\n" +
"\x04cost\x18\x06 \x01(\rR\x04cost\x12B\n" +
"\n" +
"precedence\x18\a \x01(\x0e2\".ziti.ctrl.pb.TerminatorPrecedenceR\n" +
"precedence\x12\x1e\n" +
"\n" +
"instanceId\x18\b \x01(\tR\n" +
"instanceId\x12&\n" +
"\x0einstanceSecret\x18\t \x01(\fR\x0einstanceSecret\x1a;\n" +
"\rPeerDataEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\rR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value:\x028\x01\"=\n" +
"\x17RemoveTerminatorRequest\x12\"\n" +
"\fterminatorId\x18\x01 \x01(\tR\fterminatorId\"@\n" +
"\x18RemoveTerminatorsRequest\x12$\n" +
"\rterminatorIds\x18\x01 \x03(\tR\rterminatorIds\"h\n" +
"\n" +
"Terminator\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\x18\n" +
"\abinding\x18\x02 \x01(\tR\abinding\x12\x18\n" +
"\aaddress\x18\x03 \x01(\tR\aaddress\x12\x16\n" +
"\x06marker\x18\x04 \x01(\x04R\x06marker\"X\n" +
"\x1aValidateTerminatorsRequest\x12:\n" +
"\vterminators\x18\x01 \x03(\v2\x18.ziti.ctrl.pb.TerminatorR\vterminators\"\x9a\x01\n" +
"\x1cValidateTerminatorsV2Request\x12:\n" +
"\vterminators\x18\x01 \x03(\v2\x18.ziti.ctrl.pb.TerminatorR\vterminators\x12\x1e\n" +
"\n" +
"fixInvalid\x18\x02 \x01(\bR\n" +
"fixInvalid\x12\x1e\n" +
"\n" +
"postCreate\x18\x03 \x01(\bR\n" +
"postCreate\"\x9c\x01\n" +
"\x15RouterTerminatorState\x12\x14\n" +
"\x05valid\x18\x01 \x01(\bR\x05valid\x12=\n" +
"\x06reason\x18\x02 \x01(\x0e2%.ziti.ctrl.pb.TerminatorInvalidReasonR\x06reason\x12\x16\n" +
"\x06detail\x18\x03 \x01(\tR\x06detail\x12\x16\n" +
"\x06marker\x18\x04 \x01(\x04R\x06marker\"\xd0\x01\n" +
"\x1dValidateTerminatorsV2Response\x12O\n" +
"\x06states\x18\x01 \x03(\v27.ziti.ctrl.pb.ValidateTerminatorsV2Response.StatesEntryR\x06states\x1a^\n" +
"\vStatesEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x129\n" +
"\x05value\x18\x02 \x01(\v2#.ziti.ctrl.pb.RouterTerminatorStateR\x05value:\x028\x01\"\xe1\x01\n" +
"\x17UpdateTerminatorRequest\x12\"\n" +
"\fterminatorId\x18\x01 \x01(\tR\fterminatorId\x12*\n" +
"\x10updatePrecedence\x18\x02 \x01(\bR\x10updatePrecedence\x12\x1e\n" +
"\n" +
"updateCost\x18\x03 \x01(\bR\n" +
"updateCost\x12B\n" +
"\n" +
"precedence\x18\x04 \x01(\x0e2\".ziti.ctrl.pb.TerminatorPrecedenceR\n" +
"precedence\x12\x12\n" +
"\x04cost\x18\x05 \x01(\rR\x04cost\"\\\n" +
"\bLinkConn\x12\x12\n" +
"\x04type\x18\x01 \x01(\tR\x04type\x12\x1c\n" +
"\tlocalAddr\x18\x02 \x01(\tR\tlocalAddr\x12\x1e\n" +
"\n" +
"remoteAddr\x18\x03 \x01(\tR\n" +
"remoteAddr\"e\n" +
"\rLinkConnState\x12&\n" +
"\x0estateIteration\x18\x01 \x01(\rR\x0estateIteration\x12,\n" +
"\x05conns\x18\x02 \x03(\v2\x16.ziti.ctrl.pb.LinkConnR\x05conns\"\xe1\x02\n" +
"\vRouterLinks\x12:\n" +
"\x05links\x18\x01 \x03(\v2$.ziti.ctrl.pb.RouterLinks.RouterLinkR\x05links\x12 \n" +
"\vfullRefresh\x18\x02 \x01(\bR\vfullRefresh\x1a\xf3\x01\n" +
"\n" +
"RouterLink\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\"\n" +
"\fdestRouterId\x18\x02 \x01(\tR\fdestRouterId\x12\"\n" +
"\flinkProtocol\x18\x03 \x01(\tR\flinkProtocol\x12 \n" +
"\vdialAddress\x18\x05 \x01(\tR\vdialAddress\x12\x1c\n" +
"\titeration\x18\x06 \x01(\rR\titeration\x129\n" +
"\tconnState\x18\a \x01(\v2\x1b.ziti.ctrl.pb.LinkConnStateR\tconnStateJ\x04\b\x04\x10\x05R\flinkCostTags\"k\n" +
"\x05Fault\x124\n" +
"\asubject\x18\x01 \x01(\x0e2\x1a.ziti.ctrl.pb.FaultSubjectR\asubject\x12\x0e\n" +
"\x02id\x18\x02 \x01(\tR\x02id\x12\x1c\n" +
"\titeration\x18\x03 \x01(\rR\titeration\"\xa1\x01\n" +
"\aContext\x129\n" +
"\x06fields\x18\x01 \x03(\v2!.ziti.ctrl.pb.Context.FieldsEntryR\x06fields\x12 \n" +
"\vchannelMask\x18\x02 \x01(\rR\vchannelMask\x1a9\n" +
"\vFieldsEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\xc4\x05\n" +
"\x05Route\x12\x1c\n" +
"\tcircuitId\x18\x01 \x01(\tR\tcircuitId\x12\x18\n" +
"\aattempt\x18\x02 \x01(\rR\aattempt\x122\n" +
"\x06egress\x18\x03 \x01(\v2\x1a.ziti.ctrl.pb.Route.EgressR\x06egress\x127\n" +
"\bforwards\x18\x04 \x03(\v2\x1b.ziti.ctrl.pb.Route.ForwardR\bforwards\x12/\n" +
"\acontext\x18\x05 \x01(\v2\x15.ziti.ctrl.pb.ContextR\acontext\x12\x18\n" +
"\atimeout\x18\x06 \x01(\x04R\atimeout\x121\n" +
"\x04tags\x18\a \x03(\v2\x1d.ziti.ctrl.pb.Route.TagsEntryR\x04tags\x1a\xe1\x01\n" +
"\x06Egress\x12\x18\n" +
"\abinding\x18\x01 \x01(\tR\abinding\x12\x18\n" +
"\aaddress\x18\x02 \x01(\tR\aaddress\x12 \n" +
"\vdestination\x18\x03 \x01(\tR\vdestination\x12D\n" +
"\bpeerData\x18\x04 \x03(\v2(.ziti.ctrl.pb.Route.Egress.PeerDataEntryR\bpeerData\x1a;\n" +
"\rPeerDataEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\rR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value:\x028\x01\x1a{\n" +
"\aForward\x12\x1e\n" +
"\n" +
"srcAddress\x18\x01 \x01(\tR\n" +
"srcAddress\x12\x1e\n" +
"\n" +
"dstAddress\x18\x02 \x01(\tR\n" +
"dstAddress\x120\n" +
"\adstType\x18\x03 \x01(\x0e2\x16.ziti.ctrl.pb.DestTypeR\adstType\x1a7\n" +
"\tTagsEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"9\n" +
"\aUnroute\x12\x1c\n" +
"\tcircuitId\x18\x01 \x01(\tR\tcircuitId\x12\x10\n" +
"\x03now\x18\x02 \x01(\bR\x03now\":\n" +
"\x0eInspectRequest\x12(\n" +
"\x0frequestedValues\x18\x01 \x03(\tR\x0frequestedValues\"\xc1\x01\n" +
"\x0fInspectResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x16\n" +
"\x06errors\x18\x02 \x03(\tR\x06errors\x12B\n" +
"\x06values\x18\x03 \x03(\v2*.ziti.ctrl.pb.InspectResponse.InspectValueR\x06values\x1a8\n" +
"\fInspectValue\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value\"N\n" +
"\fVerifyRouter\x12\x1a\n" +
"\brouterId\x18\x01 \x01(\tR\brouterId\x12\"\n" +
"\ffingerprints\x18\x02 \x03(\tR\ffingerprints\"\x8c\x01\n" +
"\bListener\x12\x18\n" +
"\aaddress\x18\x01 \x01(\tR\aaddress\x12\x1a\n" +
"\bprotocol\x18\x02 \x01(\tR\bprotocol\x12\x16\n" +
"\x06groups\x18\x04 \x03(\tR\x06groups\x12\"\n" +
"\flocalBinding\x18\x05 \x01(\tR\flocalBindingJ\x04\b\x03\x10\x04R\bcostTags\"A\n" +
"\tListeners\x124\n" +
"\tlisteners\x18\x01 \x03(\v2\x16.ziti.ctrl.pb.ListenerR\tlisteners\"@\n" +
"\fCtrlEndpoint\x12\x18\n" +
"\aaddress\x18\x01 \x01(\tR\aaddress\x12\x16\n" +
"\x06groups\x18\x02 \x03(\tR\x06groups\"V\n" +
"\n" +
"CtrlDetail\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x128\n" +
"\tendpoints\x18\x02 \x03(\v2\x1a.ziti.ctrl.pb.CtrlEndpointR\tendpoints\"\xa1\x01\n" +
"\x13UpdateCtrlAddresses\x12\x1c\n" +
"\taddresses\x18\x01 \x03(\tR\taddresses\x12\x14\n" +
"\x05index\x18\x02 \x01(\x04R\x05index\x12\x1a\n" +
"\bisLeader\x18\x03 \x01(\bR\bisLeader\x12:\n" +
"\vcontrollers\x18\x04 \x03(\v2\x18.ziti.ctrl.pb.CtrlDetailR\vcontrollers\"+\n" +
"\x13UpdateClusterLeader\x12\x14\n" +
"\x05index\x18\x01 \x01(\x04R\x05index\"\xa0\x01\n" +
"\x0fPeerStateChange\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\x18\n" +
"\aversion\x18\x02 \x01(\tR\aversion\x12-\n" +
"\x05state\x18\x03 \x01(\x0e2\x17.ziti.ctrl.pb.PeerStateR\x05state\x124\n" +
"\tlisteners\x18\x04 \x03(\v2\x16.ziti.ctrl.pb.ListenerR\tlisteners\"K\n" +
"\x10PeerStateChanges\x127\n" +
"\achanges\x18\x01 \x03(\v2\x1d.ziti.ctrl.pb.PeerStateChangeR\achanges\"T\n" +
"\x0eRouterMetadata\x12B\n" +
"\fcapabilities\x18\x01 \x03(\x0e2\x1e.ziti.ctrl.pb.RouterCapabilityR\fcapabilities\"\xa5\x01\n" +
"\tInterface\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12(\n" +
"\x0fhardwareAddress\x18\x02 \x01(\tR\x0fhardwareAddress\x12\x10\n" +
"\x03mtu\x18\x03 \x01(\x03R\x03mtu\x12\x14\n" +
"\x05index\x18\x04 \x01(\x03R\x05index\x12\x14\n" +
"\x05flags\x18\x05 \x01(\x04R\x05flags\x12\x1c\n" +
"\taddresses\x18\x06 \x03(\tR\taddresses\"Q\n" +
"\x16RouterInterfacesUpdate\x127\n" +
"\n" +
"interfaces\x18\x01 \x03(\v2\x17.ziti.ctrl.pb.InterfaceR\n" +
"interfaces\"\x8a\x01\n" +
"\x0fLinkStateUpdate\x12\x16\n" +
"\x06linkId\x18\x01 \x01(\tR\x06linkId\x12$\n" +
"\rlinkIteration\x18\x02 \x01(\rR\rlinkIteration\x129\n" +
"\tconnState\x18\x03 \x01(\v2\x1b.ziti.ctrl.pb.LinkConnStateR\tconnState\"\xc9\x02\n" +
"\x05Alert\x12\x1e\n" +
"\n" +
"sourceType\x18\x01 \x01(\tR\n" +
"sourceType\x12\x1a\n" +
"\bsourceId\x18\x02 \x01(\tR\bsourceId\x12\x1c\n" +
"\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x1a\n" +
"\bseverity\x18\x04 \x01(\tR\bseverity\x12\x18\n" +
"\amessage\x18\x05 \x01(\tR\amessage\x12\x18\n" +
"\adetails\x18\x06 \x03(\tR\adetails\x12R\n" +
"\x0frelatedEntities\x18\a \x03(\v2(.ziti.ctrl.pb.Alert.RelatedEntitiesEntryR\x0frelatedEntities\x1aB\n" +
"\x14RelatedEntitiesEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"5\n" +
"\x06Alerts\x12+\n" +
"\x06alerts\x18\x01 \x03(\v2\x13.ziti.ctrl.pb.AlertR\x06alerts\"D\n" +
"\x10CtrlChanListener\x12\x18\n" +
"\aaddress\x18\x01 \x01(\tR\aaddress\x12\x16\n" +
"\x06groups\x18\x02 \x03(\tR\x06groups\"Q\n" +
"\x11CtrlChanListeners\x12<\n" +
"\tlisteners\x18\x01 \x03(\v2\x1e.ziti.ctrl.pb.CtrlChanListenerR\tlisteners*\xf9\x06\n" +
"\vContentType\x12\b\n" +
"\x04Zero\x10\x00\x12\x17\n" +
"\x12CircuitRequestType\x10\xe8\a\x12\x0e\n" +
"\tFaultType\x10\xec\a\x12\x0e\n" +
"\tRouteType\x10\xed\a\x12\x10\n" +
"\vUnrouteType\x10\xee\a\x12\x10\n" +
"\vMetricsType\x10\xef\a\x12 \n" +
"\x1bTogglePipeTracesRequestType\x10\xf0\a\x12\x13\n" +
"\x0eTraceEventType\x10\xf2\a\x12 \n" +
"\x1bCreateTerminatorRequestType\x10\xf3\a\x12 \n" +
"\x1bRemoveTerminatorRequestType\x10\xf4\a\x12\x17\n" +
"\x12InspectRequestType\x10\xf5\a\x12\x18\n" +
"\x13InspectResponseType\x10\xf6\a\x12#\n" +
"\x1eValidateTerminatorsRequestType\x10\xf9\a\x12 \n" +
"\x1bUpdateTerminatorRequestType\x10\xfa\a\x12\x11\n" +
"\fSettingsType\x10\xfc\a\x12\x1c\n" +
"\x17CircuitConfirmationType\x10\x8a\b\x12\x14\n" +
"\x0fRouterLinksType\x10\x8b\b\x12\x15\n" +
"\x10VerifyRouterType\x10\x8c\b\x12\x1c\n" +
"\x17UpdateCtrlAddressesType\x10\x8d\b\x12!\n" +
"\x1cRemoveTerminatorsRequestType\x10\x8e\b\x12\x1d\n" +
"\x18QuiesceRouterRequestType\x10\x8f\b\x12\x1f\n" +
"\x1aDequiesceRouterRequestType\x10\x90\b\x12%\n" +
" ValidateTerminatorsV2RequestType\x10\x91\b\x12&\n" +
"!ValidateTerminatorsV2ResponseType\x10\x92\b\x12\"\n" +
"\x1dDecommissionRouterRequestType\x10\x93\b\x12\x1f\n" +
"\x1aPeerStateChangeRequestType\x10\x9a\b\x12#\n" +
"\x1eUpdateClusterLeaderRequestType\x10\x9b\b\x12\x1b\n" +
"\x16UpdateRouterInterfaces\x10\x9c\b\x12\x0e\n" +
"\tLinkState\x10\x9d\b\x12\x0f\n" +
"\n" +
"AlertsType\x10\x9e\b\x12\x1a\n" +
"\x15RequestClusterMembers\x10\x9f\b\x12\x1c\n" +
"\x17UpdateLinkListenersType\x10\xa0\b*\x88\x01\n" +
"\x0eControlHeaders\x12\x0e\n" +
"\n" +
"NoneHeader\x10\x00\x12\x14\n" +
"\x0fListenersHeader\x10\xe8\a\x12\x19\n" +
"\x14RouterMetadataHeader\x10\xe9\a\x12\x17\n" +
"\x12CapabilitiesHeader\x10\xea\a\x12\x1c\n" +
"\x17CtrlChanListenersHeader\x10\xeb\a*:\n" +
"\x10RouterCapability\x12\x12\n" +
"\x0eCapabilityZero\x10\x00\x12\x12\n" +
"\x0eLinkManagement\x10\x01*5\n" +
"\fSettingTypes\x12\x11\n" +
"\rUnusedSetting\x10\x00\x12\x12\n" +
"\x0eNewCtrlAddress\x10\x01*=\n" +
"\x14TerminatorPrecedence\x12\v\n" +
"\aDefault\x10\x00\x12\f\n" +
"\bRequired\x10\x01\x12\n" +
"\n" +
"\x06Failed\x10\x02*R\n" +
"\x17TerminatorInvalidReason\x12\x12\n" +
"\x0eUnknownBinding\x10\x00\x12\x15\n" +
"\x11UnknownTerminator\x10\x01\x12\f\n" +
"\bBadState\x10\x02*\x83\x01\n" +
"\fFaultSubject\x12\x10\n" +
"\fIngressFault\x10\x00\x12\x0f\n" +
"\vEgressFault\x10\x01\x12\r\n" +
"\tLinkFault\x10\x02\x12\x10\n" +
"\fForwardFault\x10\x03\x12\x1c\n" +
"\x18UnknownOwnerForwardFault\x10\x04\x12\x11\n" +
"\rLinkDuplicate\x10\x05*(\n" +
"\bDestType\x12\t\n" +
"\x05Start\x10\x00\x12\a\n" +
"\x03End\x10\x01\x12\b\n" +
"\x04Link\x10\x02*4\n" +
"\tPeerState\x12\v\n" +
"\aHealthy\x10\x00\x12\r\n" +
"\tUnhealthy\x10\x01\x12\v\n" +
"\aRemoved\x10\x02B'Z%github.com/openziti/fabric/pb/ctrl_pbb\x06proto3"
var (
file_ctrl_proto_rawDescOnce sync.Once
file_ctrl_proto_rawDescData []byte
)
func file_ctrl_proto_rawDescGZIP() []byte {
file_ctrl_proto_rawDescOnce.Do(func() {
file_ctrl_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_ctrl_proto_rawDesc), len(file_ctrl_proto_rawDesc)))
})
return file_ctrl_proto_rawDescData
}
var file_ctrl_proto_enumTypes = make([]protoimpl.EnumInfo, 9)
var file_ctrl_proto_msgTypes = make([]protoimpl.MessageInfo, 51)
var file_ctrl_proto_goTypes = []any{
(ContentType)(0), // 0: ziti.ctrl.pb.ContentType
(ControlHeaders)(0), // 1: ziti.ctrl.pb.ControlHeaders
(RouterCapability)(0), // 2: ziti.ctrl.pb.RouterCapability
(SettingTypes)(0), // 3: ziti.ctrl.pb.SettingTypes
(TerminatorPrecedence)(0), // 4: ziti.ctrl.pb.TerminatorPrecedence
(TerminatorInvalidReason)(0), // 5: ziti.ctrl.pb.TerminatorInvalidReason
(FaultSubject)(0), // 6: ziti.ctrl.pb.FaultSubject
(DestType)(0), // 7: ziti.ctrl.pb.DestType
(PeerState)(0), // 8: ziti.ctrl.pb.PeerState
(*Settings)(nil), // 9: ziti.ctrl.pb.Settings
(*CircuitRequest)(nil), // 10: ziti.ctrl.pb.CircuitRequest
(*CircuitConfirmation)(nil), // 11: ziti.ctrl.pb.CircuitConfirmation
(*CreateTerminatorRequest)(nil), // 12: ziti.ctrl.pb.CreateTerminatorRequest
(*RemoveTerminatorRequest)(nil), // 13: ziti.ctrl.pb.RemoveTerminatorRequest
(*RemoveTerminatorsRequest)(nil), // 14: ziti.ctrl.pb.RemoveTerminatorsRequest
(*Terminator)(nil), // 15: ziti.ctrl.pb.Terminator
(*ValidateTerminatorsRequest)(nil), // 16: ziti.ctrl.pb.ValidateTerminatorsRequest
(*ValidateTerminatorsV2Request)(nil), // 17: ziti.ctrl.pb.ValidateTerminatorsV2Request
(*RouterTerminatorState)(nil), // 18: ziti.ctrl.pb.RouterTerminatorState
(*ValidateTerminatorsV2Response)(nil), // 19: ziti.ctrl.pb.ValidateTerminatorsV2Response
(*UpdateTerminatorRequest)(nil), // 20: ziti.ctrl.pb.UpdateTerminatorRequest
(*LinkConn)(nil), // 21: ziti.ctrl.pb.LinkConn
(*LinkConnState)(nil), // 22: ziti.ctrl.pb.LinkConnState
(*RouterLinks)(nil), // 23: ziti.ctrl.pb.RouterLinks
(*Fault)(nil), // 24: ziti.ctrl.pb.Fault
(*Context)(nil), // 25: ziti.ctrl.pb.Context
(*Route)(nil), // 26: ziti.ctrl.pb.Route
(*Unroute)(nil), // 27: ziti.ctrl.pb.Unroute
(*InspectRequest)(nil), // 28: ziti.ctrl.pb.InspectRequest
(*InspectResponse)(nil), // 29: ziti.ctrl.pb.InspectResponse
(*VerifyRouter)(nil), // 30: ziti.ctrl.pb.VerifyRouter
(*Listener)(nil), // 31: ziti.ctrl.pb.Listener
(*Listeners)(nil), // 32: ziti.ctrl.pb.Listeners
(*CtrlEndpoint)(nil), // 33: ziti.ctrl.pb.CtrlEndpoint
(*CtrlDetail)(nil), // 34: ziti.ctrl.pb.CtrlDetail
(*UpdateCtrlAddresses)(nil), // 35: ziti.ctrl.pb.UpdateCtrlAddresses
(*UpdateClusterLeader)(nil), // 36: ziti.ctrl.pb.UpdateClusterLeader
(*PeerStateChange)(nil), // 37: ziti.ctrl.pb.PeerStateChange
(*PeerStateChanges)(nil), // 38: ziti.ctrl.pb.PeerStateChanges
(*RouterMetadata)(nil), // 39: ziti.ctrl.pb.RouterMetadata
(*Interface)(nil), // 40: ziti.ctrl.pb.Interface
(*RouterInterfacesUpdate)(nil), // 41: ziti.ctrl.pb.RouterInterfacesUpdate
(*LinkStateUpdate)(nil), // 42: ziti.ctrl.pb.LinkStateUpdate
(*Alert)(nil), // 43: ziti.ctrl.pb.Alert
(*Alerts)(nil), // 44: ziti.ctrl.pb.Alerts
(*CtrlChanListener)(nil), // 45: ziti.ctrl.pb.CtrlChanListener
(*CtrlChanListeners)(nil), // 46: ziti.ctrl.pb.CtrlChanListeners
nil, // 47: ziti.ctrl.pb.Settings.DataEntry
nil, // 48: ziti.ctrl.pb.CircuitRequest.PeerDataEntry
nil, // 49: ziti.ctrl.pb.CircuitConfirmation.IdleTimesEntry
nil, // 50: ziti.ctrl.pb.CreateTerminatorRequest.PeerDataEntry
nil, // 51: ziti.ctrl.pb.ValidateTerminatorsV2Response.StatesEntry
(*RouterLinks_RouterLink)(nil), // 52: ziti.ctrl.pb.RouterLinks.RouterLink
nil, // 53: ziti.ctrl.pb.Context.FieldsEntry
(*Route_Egress)(nil), // 54: ziti.ctrl.pb.Route.Egress
(*Route_Forward)(nil), // 55: ziti.ctrl.pb.Route.Forward
nil, // 56: ziti.ctrl.pb.Route.TagsEntry
nil, // 57: ziti.ctrl.pb.Route.Egress.PeerDataEntry
(*InspectResponse_InspectValue)(nil), // 58: ziti.ctrl.pb.InspectResponse.InspectValue
nil, // 59: ziti.ctrl.pb.Alert.RelatedEntitiesEntry
}
var file_ctrl_proto_depIdxs = []int32{
47, // 0: ziti.ctrl.pb.Settings.data:type_name -> ziti.ctrl.pb.Settings.DataEntry
48, // 1: ziti.ctrl.pb.CircuitRequest.peerData:type_name -> ziti.ctrl.pb.CircuitRequest.PeerDataEntry
49, // 2: ziti.ctrl.pb.CircuitConfirmation.idleTimes:type_name -> ziti.ctrl.pb.CircuitConfirmation.IdleTimesEntry
50, // 3: ziti.ctrl.pb.CreateTerminatorRequest.peerData:type_name -> ziti.ctrl.pb.CreateTerminatorRequest.PeerDataEntry
4, // 4: ziti.ctrl.pb.CreateTerminatorRequest.precedence:type_name -> ziti.ctrl.pb.TerminatorPrecedence
15, // 5: ziti.ctrl.pb.ValidateTerminatorsRequest.terminators:type_name -> ziti.ctrl.pb.Terminator
15, // 6: ziti.ctrl.pb.ValidateTerminatorsV2Request.terminators:type_name -> ziti.ctrl.pb.Terminator
5, // 7: ziti.ctrl.pb.RouterTerminatorState.reason:type_name -> ziti.ctrl.pb.TerminatorInvalidReason
51, // 8: ziti.ctrl.pb.ValidateTerminatorsV2Response.states:type_name -> ziti.ctrl.pb.ValidateTerminatorsV2Response.StatesEntry
4, // 9: ziti.ctrl.pb.UpdateTerminatorRequest.precedence:type_name -> ziti.ctrl.pb.TerminatorPrecedence
21, // 10: ziti.ctrl.pb.LinkConnState.conns:type_name -> ziti.ctrl.pb.LinkConn
52, // 11: ziti.ctrl.pb.RouterLinks.links:type_name -> ziti.ctrl.pb.RouterLinks.RouterLink
6, // 12: ziti.ctrl.pb.Fault.subject:type_name -> ziti.ctrl.pb.FaultSubject
53, // 13: ziti.ctrl.pb.Context.fields:type_name -> ziti.ctrl.pb.Context.FieldsEntry
54, // 14: ziti.ctrl.pb.Route.egress:type_name -> ziti.ctrl.pb.Route.Egress
55, // 15: ziti.ctrl.pb.Route.forwards:type_name -> ziti.ctrl.pb.Route.Forward
25, // 16: ziti.ctrl.pb.Route.context:type_name -> ziti.ctrl.pb.Context
56, // 17: ziti.ctrl.pb.Route.tags:type_name -> ziti.ctrl.pb.Route.TagsEntry
58, // 18: ziti.ctrl.pb.InspectResponse.values:type_name -> ziti.ctrl.pb.InspectResponse.InspectValue
31, // 19: ziti.ctrl.pb.Listeners.listeners:type_name -> ziti.ctrl.pb.Listener
33, // 20: ziti.ctrl.pb.CtrlDetail.endpoints:type_name -> ziti.ctrl.pb.CtrlEndpoint
34, // 21: ziti.ctrl.pb.UpdateCtrlAddresses.controllers:type_name -> ziti.ctrl.pb.CtrlDetail
8, // 22: ziti.ctrl.pb.PeerStateChange.state:type_name -> ziti.ctrl.pb.PeerState
31, // 23: ziti.ctrl.pb.PeerStateChange.listeners:type_name -> ziti.ctrl.pb.Listener
37, // 24: ziti.ctrl.pb.PeerStateChanges.changes:type_name -> ziti.ctrl.pb.PeerStateChange
2, // 25: ziti.ctrl.pb.RouterMetadata.capabilities:type_name -> ziti.ctrl.pb.RouterCapability
40, // 26: ziti.ctrl.pb.RouterInterfacesUpdate.interfaces:type_name -> ziti.ctrl.pb.Interface
22, // 27: ziti.ctrl.pb.LinkStateUpdate.connState:type_name -> ziti.ctrl.pb.LinkConnState
59, // 28: ziti.ctrl.pb.Alert.relatedEntities:type_name -> ziti.ctrl.pb.Alert.RelatedEntitiesEntry
43, // 29: ziti.ctrl.pb.Alerts.alerts:type_name -> ziti.ctrl.pb.Alert
45, // 30: ziti.ctrl.pb.CtrlChanListeners.listeners:type_name -> ziti.ctrl.pb.CtrlChanListener
18, // 31: ziti.ctrl.pb.ValidateTerminatorsV2Response.StatesEntry.value:type_name -> ziti.ctrl.pb.RouterTerminatorState
22, // 32: ziti.ctrl.pb.RouterLinks.RouterLink.connState:type_name -> ziti.ctrl.pb.LinkConnState
57, // 33: ziti.ctrl.pb.Route.Egress.peerData:type_name -> ziti.ctrl.pb.Route.Egress.PeerDataEntry
7, // 34: ziti.ctrl.pb.Route.Forward.dstType:type_name -> ziti.ctrl.pb.DestType
35, // [35:35] is the sub-list for method output_type
35, // [35:35] is the sub-list for method input_type
35, // [35:35] is the sub-list for extension type_name
35, // [35:35] is the sub-list for extension extendee
0, // [0:35] is the sub-list for field type_name
}
func init() { file_ctrl_proto_init() }
func file_ctrl_proto_init() {
if File_ctrl_proto != nil {
return
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_ctrl_proto_rawDesc), len(file_ctrl_proto_rawDesc)),
NumEnums: 9,
NumMessages: 51,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_ctrl_proto_goTypes,
DependencyIndexes: file_ctrl_proto_depIdxs,
EnumInfos: file_ctrl_proto_enumTypes,
MessageInfos: file_ctrl_proto_msgTypes,
}.Build()
File_ctrl_proto = out.File
file_ctrl_proto_goTypes = nil
file_ctrl_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink