Documentation ¶
Index ¶
- Variables
- func DecodeTags(tags map[string]*TagValue) map[string]interface{}
- func EncodeProtobuf(v TypedMessage) ([]byte, error)
- func EncodeTags(tags map[string]interface{}) (map[string]*TagValue, error)
- type AddPeerRequest
- func (*AddPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddPeerRequest) GetAddr() string
- func (request *AddPeerRequest) GetContentType() int32
- func (x *AddPeerRequest) GetCtx() *ChangeContext
- func (x *AddPeerRequest) GetId() string
- func (x *AddPeerRequest) GetIsVoter() bool
- func (*AddPeerRequest) ProtoMessage()
- func (x *AddPeerRequest) ProtoReflect() protoreflect.Message
- func (x *AddPeerRequest) Reset()
- func (x *AddPeerRequest) String() string
- type ChangeContext
- func (*ChangeContext) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeContext) GetChangeAuthor() string
- func (x *ChangeContext) GetTraceId() string
- func (*ChangeContext) ProtoMessage()
- func (x *ChangeContext) ProtoReflect() protoreflect.Message
- func (x *ChangeContext) Reset()
- func (x *ChangeContext) String() string
- type CommandType
- func (CommandType) Descriptor() protoreflect.EnumDescriptor
- func (x CommandType) Enum() *CommandType
- func (CommandType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CommandType) Number() protoreflect.EnumNumber
- func (x CommandType) String() string
- func (CommandType) Type() protoreflect.EnumType
- type ContentType
- func (ContentType) Descriptor() protoreflect.EnumDescriptor
- func (x ContentType) Enum() *ContentType
- func (ContentType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContentType) Number() protoreflect.EnumNumber
- func (x ContentType) String() string
- func (ContentType) Type() protoreflect.EnumType
- type CreateEntityCommand
- func (*CreateEntityCommand) Descriptor() ([]byte, []int)deprecated
- func (x *CreateEntityCommand) GetCommandType() int32
- func (x *CreateEntityCommand) GetCtx() *ChangeContext
- func (x *CreateEntityCommand) GetEntityData() []byte
- func (x *CreateEntityCommand) GetEntityType() string
- func (x *CreateEntityCommand) GetFlags() uint32
- func (*CreateEntityCommand) ProtoMessage()
- func (x *CreateEntityCommand) ProtoReflect() protoreflect.Message
- func (x *CreateEntityCommand) Reset()
- func (x *CreateEntityCommand) String() string
- type DeleteEntityCommand
- func (*DeleteEntityCommand) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteEntityCommand) GetCommandType() int32
- func (x *DeleteEntityCommand) GetCtx() *ChangeContext
- func (x *DeleteEntityCommand) GetEntityId() string
- func (x *DeleteEntityCommand) GetEntityType() string
- func (*DeleteEntityCommand) ProtoMessage()
- func (x *DeleteEntityCommand) ProtoReflect() protoreflect.Message
- func (x *DeleteEntityCommand) Reset()
- func (x *DeleteEntityCommand) String() string
- type RemovePeerRequest
- func (*RemovePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (request *RemovePeerRequest) GetContentType() int32
- func (x *RemovePeerRequest) GetCtx() *ChangeContext
- func (x *RemovePeerRequest) GetId() string
- func (*RemovePeerRequest) ProtoMessage()
- func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message
- func (x *RemovePeerRequest) Reset()
- func (x *RemovePeerRequest) String() string
- type Router
- func (*Router) Descriptor() ([]byte, []int)deprecated
- func (x *Router) GetCost() uint32
- func (x *Router) GetDisabled() bool
- func (x *Router) GetFingerprint() []byte
- func (x *Router) GetId() string
- func (x *Router) GetName() string
- func (x *Router) GetNoTraversal() bool
- func (x *Router) GetTags() map[string]*TagValue
- func (*Router) ProtoMessage()
- func (x *Router) ProtoReflect() protoreflect.Message
- func (x *Router) Reset()
- func (x *Router) String() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetId() string
- func (x *Service) GetName() string
- func (x *Service) GetTags() map[string]*TagValue
- func (x *Service) GetTerminatorStrategy() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type SyncSnapshotCommand
- func (*SyncSnapshotCommand) Descriptor() ([]byte, []int)deprecated
- func (x *SyncSnapshotCommand) GetCommandType() int32
- func (x *SyncSnapshotCommand) GetSnapshot() []byte
- func (x *SyncSnapshotCommand) GetSnapshotId() string
- func (*SyncSnapshotCommand) ProtoMessage()
- func (x *SyncSnapshotCommand) ProtoReflect() protoreflect.Message
- func (x *SyncSnapshotCommand) Reset()
- func (x *SyncSnapshotCommand) String() string
- type TagValue
- func (*TagValue) Descriptor() ([]byte, []int)deprecated
- func (x *TagValue) GetBoolValue() bool
- func (x *TagValue) GetFpValue() float64
- func (x *TagValue) GetNilValue() bool
- func (x *TagValue) GetStringValue() string
- func (m *TagValue) GetValue() isTagValue_Value
- func (*TagValue) ProtoMessage()
- func (x *TagValue) ProtoReflect() protoreflect.Message
- func (x *TagValue) Reset()
- func (x *TagValue) String() string
- type TagValue_BoolValue
- type TagValue_FpValue
- type TagValue_NilValue
- type TagValue_StringValue
- type Terminator
- func (*Terminator) Descriptor() ([]byte, []int)deprecated
- func (x *Terminator) GetAddress() string
- func (x *Terminator) GetBinding() string
- func (x *Terminator) GetCost() uint32
- func (x *Terminator) GetHostId() string
- func (x *Terminator) GetId() string
- func (x *Terminator) GetInstanceId() string
- func (x *Terminator) GetInstanceSecret() []byte
- func (x *Terminator) GetIsSystem() bool
- func (x *Terminator) GetPeerData() map[uint32][]byte
- func (x *Terminator) GetPrecedence() uint32
- func (x *Terminator) GetRouterId() string
- func (x *Terminator) GetServiceId() string
- func (x *Terminator) GetTags() map[string]*TagValue
- func (*Terminator) ProtoMessage()
- func (x *Terminator) ProtoReflect() protoreflect.Message
- func (x *Terminator) Reset()
- func (x *Terminator) String() string
- type TransferLeadershipRequest
- func (*TransferLeadershipRequest) Descriptor() ([]byte, []int)deprecated
- func (request *TransferLeadershipRequest) GetContentType() int32
- func (x *TransferLeadershipRequest) GetCtx() *ChangeContext
- func (x *TransferLeadershipRequest) GetId() string
- func (*TransferLeadershipRequest) ProtoMessage()
- func (x *TransferLeadershipRequest) ProtoReflect() protoreflect.Message
- func (x *TransferLeadershipRequest) Reset()
- func (x *TransferLeadershipRequest) String() string
- type TypedMessage
- type UpdateEntityCommand
- func (*UpdateEntityCommand) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEntityCommand) GetCommandType() int32
- func (x *UpdateEntityCommand) GetCtx() *ChangeContext
- func (x *UpdateEntityCommand) GetEntityData() []byte
- func (x *UpdateEntityCommand) GetEntityType() string
- func (x *UpdateEntityCommand) GetFlags() uint32
- func (x *UpdateEntityCommand) GetUpdatedFields() []string
- func (*UpdateEntityCommand) ProtoMessage()
- func (x *UpdateEntityCommand) ProtoReflect() protoreflect.Message
- func (x *UpdateEntityCommand) Reset()
- func (x *UpdateEntityCommand) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ContentType_name = map[int32]string{ 0: "ContentTypeZero", 2050: "NewLogEntryType", 2051: "ErrorResponseType", 2052: "SuccessResponseType", 2053: "AddPeerRequestType", 2054: "RemovePeerRequestType", 2055: "TransferLeadershipRequestType", } ContentType_value = map[string]int32{ "ContentTypeZero": 0, "NewLogEntryType": 2050, "ErrorResponseType": 2051, "SuccessResponseType": 2052, "AddPeerRequestType": 2053, "RemovePeerRequestType": 2054, "TransferLeadershipRequestType": 2055, } )
Enum value maps for ContentType.
var ( CommandType_name = map[int32]string{ 0: "Zero", 1: "CreateEntityType", 2: "UpdateEntityType", 3: "DeleteEntityType", 10: "SyncSnapshot", } CommandType_value = map[string]int32{ "Zero": 0, "CreateEntityType": 1, "UpdateEntityType": 2, "DeleteEntityType": 3, "SyncSnapshot": 10, } )
Enum value maps for CommandType.
var File_cmd_proto protoreflect.FileDescriptor
Functions ¶
func DecodeTags ¶
func EncodeProtobuf ¶
func EncodeProtobuf(v TypedMessage) ([]byte, error)
EncodeProtobuf returns the encoded message, prefixed with the command type
Types ¶
type AddPeerRequest ¶ added in v0.22.29
type AddPeerRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` IsVoter bool `protobuf:"varint,3,opt,name=isVoter,proto3" json:"isVoter,omitempty"` Ctx *ChangeContext `protobuf:"bytes,4,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*AddPeerRequest) Descriptor
deprecated
added in
v0.22.29
func (*AddPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddPeerRequest.ProtoReflect.Descriptor instead.
func (*AddPeerRequest) GetAddr ¶ added in v0.22.29
func (x *AddPeerRequest) GetAddr() string
func (*AddPeerRequest) GetContentType ¶ added in v0.22.29
func (request *AddPeerRequest) GetContentType() int32
func (*AddPeerRequest) GetCtx ¶ added in v0.22.29
func (x *AddPeerRequest) GetCtx() *ChangeContext
func (*AddPeerRequest) GetId ¶ added in v0.22.29
func (x *AddPeerRequest) GetId() string
func (*AddPeerRequest) GetIsVoter ¶ added in v0.22.29
func (x *AddPeerRequest) GetIsVoter() bool
func (*AddPeerRequest) ProtoMessage ¶ added in v0.22.29
func (*AddPeerRequest) ProtoMessage()
func (*AddPeerRequest) ProtoReflect ¶ added in v0.22.29
func (x *AddPeerRequest) ProtoReflect() protoreflect.Message
func (*AddPeerRequest) Reset ¶ added in v0.22.29
func (x *AddPeerRequest) Reset()
func (*AddPeerRequest) String ¶ added in v0.22.29
func (x *AddPeerRequest) String() string
type ChangeContext ¶ added in v0.22.29
type ChangeContext struct { ChangeAuthor string `protobuf:"bytes,1,opt,name=changeAuthor,proto3" json:"changeAuthor,omitempty"` TraceId string `protobuf:"bytes,2,opt,name=traceId,proto3" json:"traceId,omitempty"` // contains filtered or unexported fields }
func (*ChangeContext) Descriptor
deprecated
added in
v0.22.29
func (*ChangeContext) Descriptor() ([]byte, []int)
Deprecated: Use ChangeContext.ProtoReflect.Descriptor instead.
func (*ChangeContext) GetChangeAuthor ¶ added in v0.22.29
func (x *ChangeContext) GetChangeAuthor() string
func (*ChangeContext) GetTraceId ¶ added in v0.22.29
func (x *ChangeContext) GetTraceId() string
func (*ChangeContext) ProtoMessage ¶ added in v0.22.29
func (*ChangeContext) ProtoMessage()
func (*ChangeContext) ProtoReflect ¶ added in v0.22.29
func (x *ChangeContext) ProtoReflect() protoreflect.Message
func (*ChangeContext) Reset ¶ added in v0.22.29
func (x *ChangeContext) Reset()
func (*ChangeContext) String ¶ added in v0.22.29
func (x *ChangeContext) String() string
type CommandType ¶
type CommandType int32
const ( CommandType_Zero CommandType = 0 CommandType_CreateEntityType CommandType = 1 CommandType_UpdateEntityType CommandType = 2 CommandType_DeleteEntityType CommandType = 3 CommandType_SyncSnapshot CommandType = 10 )
func (CommandType) Descriptor ¶
func (CommandType) Descriptor() protoreflect.EnumDescriptor
func (CommandType) Enum ¶
func (x CommandType) Enum() *CommandType
func (CommandType) EnumDescriptor
deprecated
func (CommandType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CommandType.Descriptor instead.
func (CommandType) Number ¶
func (x CommandType) Number() protoreflect.EnumNumber
func (CommandType) String ¶
func (x CommandType) String() string
func (CommandType) Type ¶
func (CommandType) Type() protoreflect.EnumType
type ContentType ¶ added in v0.22.29
type ContentType int32
ContentTypes should be in the range 2000 - 2999, to ensure they don't overlap with ctrl_pb messages
const ( ContentType_ContentTypeZero ContentType = 0 ContentType_NewLogEntryType ContentType = 2050 ContentType_ErrorResponseType ContentType = 2051 ContentType_SuccessResponseType ContentType = 2052 ContentType_AddPeerRequestType ContentType = 2053 ContentType_RemovePeerRequestType ContentType = 2054 ContentType_TransferLeadershipRequestType ContentType = 2055 )
func (ContentType) Descriptor ¶ added in v0.22.29
func (ContentType) Descriptor() protoreflect.EnumDescriptor
func (ContentType) Enum ¶ added in v0.22.29
func (x ContentType) Enum() *ContentType
func (ContentType) EnumDescriptor
deprecated
added in
v0.22.29
func (ContentType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContentType.Descriptor instead.
func (ContentType) Number ¶ added in v0.22.29
func (x ContentType) Number() protoreflect.EnumNumber
func (ContentType) String ¶ added in v0.22.29
func (x ContentType) String() string
func (ContentType) Type ¶ added in v0.22.29
func (ContentType) Type() protoreflect.EnumType
type CreateEntityCommand ¶
type CreateEntityCommand struct { EntityType string `protobuf:"bytes,1,opt,name=entityType,proto3" json:"entityType,omitempty"` EntityData []byte `protobuf:"bytes,2,opt,name=entityData,proto3" json:"entityData,omitempty"` Flags uint32 `protobuf:"varint,3,opt,name=flags,proto3" json:"flags,omitempty"` Ctx *ChangeContext `protobuf:"bytes,4,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*CreateEntityCommand) Descriptor
deprecated
func (*CreateEntityCommand) Descriptor() ([]byte, []int)
Deprecated: Use CreateEntityCommand.ProtoReflect.Descriptor instead.
func (*CreateEntityCommand) GetCommandType ¶
func (x *CreateEntityCommand) GetCommandType() int32
func (*CreateEntityCommand) GetCtx ¶ added in v0.22.29
func (x *CreateEntityCommand) GetCtx() *ChangeContext
func (*CreateEntityCommand) GetEntityData ¶
func (x *CreateEntityCommand) GetEntityData() []byte
func (*CreateEntityCommand) GetEntityType ¶
func (x *CreateEntityCommand) GetEntityType() string
func (*CreateEntityCommand) GetFlags ¶ added in v0.19.31
func (x *CreateEntityCommand) GetFlags() uint32
func (*CreateEntityCommand) ProtoMessage ¶
func (*CreateEntityCommand) ProtoMessage()
func (*CreateEntityCommand) ProtoReflect ¶
func (x *CreateEntityCommand) ProtoReflect() protoreflect.Message
func (*CreateEntityCommand) Reset ¶
func (x *CreateEntityCommand) Reset()
func (*CreateEntityCommand) String ¶
func (x *CreateEntityCommand) String() string
type DeleteEntityCommand ¶
type DeleteEntityCommand struct { EntityId string `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"` EntityType string `protobuf:"bytes,2,opt,name=entityType,proto3" json:"entityType,omitempty"` Ctx *ChangeContext `protobuf:"bytes,3,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*DeleteEntityCommand) Descriptor
deprecated
func (*DeleteEntityCommand) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEntityCommand.ProtoReflect.Descriptor instead.
func (*DeleteEntityCommand) GetCommandType ¶
func (x *DeleteEntityCommand) GetCommandType() int32
func (*DeleteEntityCommand) GetCtx ¶ added in v0.22.29
func (x *DeleteEntityCommand) GetCtx() *ChangeContext
func (*DeleteEntityCommand) GetEntityId ¶
func (x *DeleteEntityCommand) GetEntityId() string
func (*DeleteEntityCommand) GetEntityType ¶
func (x *DeleteEntityCommand) GetEntityType() string
func (*DeleteEntityCommand) ProtoMessage ¶
func (*DeleteEntityCommand) ProtoMessage()
func (*DeleteEntityCommand) ProtoReflect ¶
func (x *DeleteEntityCommand) ProtoReflect() protoreflect.Message
func (*DeleteEntityCommand) Reset ¶
func (x *DeleteEntityCommand) Reset()
func (*DeleteEntityCommand) String ¶
func (x *DeleteEntityCommand) String() string
type RemovePeerRequest ¶ added in v0.22.29
type RemovePeerRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Ctx *ChangeContext `protobuf:"bytes,2,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*RemovePeerRequest) Descriptor
deprecated
added in
v0.22.29
func (*RemovePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemovePeerRequest.ProtoReflect.Descriptor instead.
func (*RemovePeerRequest) GetContentType ¶ added in v0.22.29
func (request *RemovePeerRequest) GetContentType() int32
func (*RemovePeerRequest) GetCtx ¶ added in v0.22.29
func (x *RemovePeerRequest) GetCtx() *ChangeContext
func (*RemovePeerRequest) GetId ¶ added in v0.22.29
func (x *RemovePeerRequest) GetId() string
func (*RemovePeerRequest) ProtoMessage ¶ added in v0.22.29
func (*RemovePeerRequest) ProtoMessage()
func (*RemovePeerRequest) ProtoReflect ¶ added in v0.22.29
func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message
func (*RemovePeerRequest) Reset ¶ added in v0.22.29
func (x *RemovePeerRequest) Reset()
func (*RemovePeerRequest) String ¶ added in v0.22.29
func (x *RemovePeerRequest) String() string
type Router ¶
type Router struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Fingerprint []byte `protobuf:"bytes,3,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"` Cost uint32 `protobuf:"varint,4,opt,name=cost,proto3" json:"cost,omitempty"` NoTraversal bool `protobuf:"varint,5,opt,name=noTraversal,proto3" json:"noTraversal,omitempty"` Disabled bool `protobuf:"varint,6,opt,name=disabled,proto3" json:"disabled,omitempty"` Tags map[string]*TagValue `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Router) Descriptor
deprecated
func (*Router) GetDisabled ¶ added in v0.22.75
func (*Router) GetFingerprint ¶
func (*Router) GetNoTraversal ¶
func (*Router) ProtoMessage ¶
func (*Router) ProtoMessage()
func (*Router) ProtoReflect ¶
func (x *Router) ProtoReflect() protoreflect.Message
type Service ¶
type Service struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` TerminatorStrategy string `protobuf:"bytes,3,opt,name=terminatorStrategy,proto3" json:"terminatorStrategy,omitempty"` Tags map[string]*TagValue `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetTerminatorStrategy ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type SyncSnapshotCommand ¶ added in v0.19.48
type SyncSnapshotCommand struct { SnapshotId string `protobuf:"bytes,1,opt,name=snapshotId,proto3" json:"snapshotId,omitempty"` Snapshot []byte `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // contains filtered or unexported fields }
func (*SyncSnapshotCommand) Descriptor
deprecated
added in
v0.19.48
func (*SyncSnapshotCommand) Descriptor() ([]byte, []int)
Deprecated: Use SyncSnapshotCommand.ProtoReflect.Descriptor instead.
func (*SyncSnapshotCommand) GetCommandType ¶ added in v0.19.48
func (x *SyncSnapshotCommand) GetCommandType() int32
func (*SyncSnapshotCommand) GetSnapshot ¶ added in v0.19.48
func (x *SyncSnapshotCommand) GetSnapshot() []byte
func (*SyncSnapshotCommand) GetSnapshotId ¶ added in v0.19.48
func (x *SyncSnapshotCommand) GetSnapshotId() string
func (*SyncSnapshotCommand) ProtoMessage ¶ added in v0.19.48
func (*SyncSnapshotCommand) ProtoMessage()
func (*SyncSnapshotCommand) ProtoReflect ¶ added in v0.19.48
func (x *SyncSnapshotCommand) ProtoReflect() protoreflect.Message
func (*SyncSnapshotCommand) Reset ¶ added in v0.19.48
func (x *SyncSnapshotCommand) Reset()
func (*SyncSnapshotCommand) String ¶ added in v0.19.48
func (x *SyncSnapshotCommand) String() string
type TagValue ¶
type TagValue struct { // Types that are assignable to Value: // *TagValue_BoolValue // *TagValue_StringValue // *TagValue_FpValue // *TagValue_NilValue Value isTagValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*TagValue) Descriptor
deprecated
func (*TagValue) GetBoolValue ¶
func (*TagValue) GetFpValue ¶
func (*TagValue) GetNilValue ¶
func (*TagValue) GetStringValue ¶
func (*TagValue) ProtoMessage ¶
func (*TagValue) ProtoMessage()
func (*TagValue) ProtoReflect ¶
func (x *TagValue) ProtoReflect() protoreflect.Message
type TagValue_BoolValue ¶
type TagValue_BoolValue struct {
BoolValue bool `protobuf:"varint,1,opt,name=boolValue,proto3,oneof"`
}
type TagValue_FpValue ¶
type TagValue_FpValue struct {
FpValue float64 `protobuf:"fixed64,3,opt,name=fpValue,proto3,oneof"`
}
type TagValue_NilValue ¶
type TagValue_NilValue struct {
NilValue bool `protobuf:"varint,4,opt,name=nilValue,proto3,oneof"`
}
type TagValue_StringValue ¶
type TagValue_StringValue struct {
StringValue string `protobuf:"bytes,2,opt,name=stringValue,proto3,oneof"`
}
type Terminator ¶
type Terminator struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ServiceId string `protobuf:"bytes,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"` RouterId string `protobuf:"bytes,3,opt,name=routerId,proto3" json:"routerId,omitempty"` Binding string `protobuf:"bytes,4,opt,name=binding,proto3" json:"binding,omitempty"` Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"` InstanceId string `protobuf:"bytes,6,opt,name=instanceId,proto3" json:"instanceId,omitempty"` InstanceSecret []byte `protobuf:"bytes,7,opt,name=instanceSecret,proto3" json:"instanceSecret,omitempty"` Cost uint32 `protobuf:"varint,8,opt,name=cost,proto3" json:"cost,omitempty"` Precedence uint32 `protobuf:"varint,9,opt,name=precedence,proto3" json:"precedence,omitempty"` PeerData map[uint32][]byte `` /* 159-byte string literal not displayed */ Tags map[string]*TagValue `` /* 150-byte string literal not displayed */ HostId string `protobuf:"bytes,12,opt,name=hostId,proto3" json:"hostId,omitempty"` IsSystem bool `protobuf:"varint,13,opt,name=isSystem,proto3" json:"isSystem,omitempty"` // contains filtered or unexported fields }
func (*Terminator) Descriptor
deprecated
func (*Terminator) Descriptor() ([]byte, []int)
Deprecated: Use Terminator.ProtoReflect.Descriptor instead.
func (*Terminator) GetAddress ¶
func (x *Terminator) GetAddress() string
func (*Terminator) GetBinding ¶
func (x *Terminator) GetBinding() string
func (*Terminator) GetCost ¶
func (x *Terminator) GetCost() uint32
func (*Terminator) GetHostId ¶ added in v0.19.23
func (x *Terminator) GetHostId() string
func (*Terminator) GetId ¶
func (x *Terminator) GetId() string
func (*Terminator) GetInstanceId ¶ added in v0.19.0
func (x *Terminator) GetInstanceId() string
func (*Terminator) GetInstanceSecret ¶ added in v0.19.0
func (x *Terminator) GetInstanceSecret() []byte
func (*Terminator) GetIsSystem ¶ added in v0.21.39
func (x *Terminator) GetIsSystem() bool
func (*Terminator) GetPeerData ¶
func (x *Terminator) GetPeerData() map[uint32][]byte
func (*Terminator) GetPrecedence ¶
func (x *Terminator) GetPrecedence() uint32
func (*Terminator) GetRouterId ¶
func (x *Terminator) GetRouterId() string
func (*Terminator) GetServiceId ¶
func (x *Terminator) GetServiceId() string
func (*Terminator) GetTags ¶
func (x *Terminator) GetTags() map[string]*TagValue
func (*Terminator) ProtoMessage ¶
func (*Terminator) ProtoMessage()
func (*Terminator) ProtoReflect ¶
func (x *Terminator) ProtoReflect() protoreflect.Message
func (*Terminator) Reset ¶
func (x *Terminator) Reset()
func (*Terminator) String ¶
func (x *Terminator) String() string
type TransferLeadershipRequest ¶ added in v0.22.31
type TransferLeadershipRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Ctx *ChangeContext `protobuf:"bytes,2,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*TransferLeadershipRequest) Descriptor
deprecated
added in
v0.22.31
func (*TransferLeadershipRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransferLeadershipRequest.ProtoReflect.Descriptor instead.
func (*TransferLeadershipRequest) GetContentType ¶ added in v0.22.31
func (request *TransferLeadershipRequest) GetContentType() int32
func (*TransferLeadershipRequest) GetCtx ¶ added in v0.22.31
func (x *TransferLeadershipRequest) GetCtx() *ChangeContext
func (*TransferLeadershipRequest) GetId ¶ added in v0.22.31
func (x *TransferLeadershipRequest) GetId() string
func (*TransferLeadershipRequest) ProtoMessage ¶ added in v0.22.31
func (*TransferLeadershipRequest) ProtoMessage()
func (*TransferLeadershipRequest) ProtoReflect ¶ added in v0.22.31
func (x *TransferLeadershipRequest) ProtoReflect() protoreflect.Message
func (*TransferLeadershipRequest) Reset ¶ added in v0.22.31
func (x *TransferLeadershipRequest) Reset()
func (*TransferLeadershipRequest) String ¶ added in v0.22.31
func (x *TransferLeadershipRequest) String() string
type TypedMessage ¶
TypedMessage instances are protobuf messages which know their command type
type UpdateEntityCommand ¶
type UpdateEntityCommand struct { EntityType string `protobuf:"bytes,1,opt,name=entityType,proto3" json:"entityType,omitempty"` EntityData []byte `protobuf:"bytes,2,opt,name=entityData,proto3" json:"entityData,omitempty"` UpdatedFields []string `protobuf:"bytes,3,rep,name=updatedFields,proto3" json:"updatedFields,omitempty"` Flags uint32 `protobuf:"varint,4,opt,name=flags,proto3" json:"flags,omitempty"` Ctx *ChangeContext `protobuf:"bytes,5,opt,name=ctx,proto3" json:"ctx,omitempty"` // contains filtered or unexported fields }
func (*UpdateEntityCommand) Descriptor
deprecated
func (*UpdateEntityCommand) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEntityCommand.ProtoReflect.Descriptor instead.
func (*UpdateEntityCommand) GetCommandType ¶
func (x *UpdateEntityCommand) GetCommandType() int32
func (*UpdateEntityCommand) GetCtx ¶ added in v0.22.29
func (x *UpdateEntityCommand) GetCtx() *ChangeContext
func (*UpdateEntityCommand) GetEntityData ¶
func (x *UpdateEntityCommand) GetEntityData() []byte
func (*UpdateEntityCommand) GetEntityType ¶
func (x *UpdateEntityCommand) GetEntityType() string
func (*UpdateEntityCommand) GetFlags ¶ added in v0.19.31
func (x *UpdateEntityCommand) GetFlags() uint32
func (*UpdateEntityCommand) GetUpdatedFields ¶
func (x *UpdateEntityCommand) GetUpdatedFields() []string
func (*UpdateEntityCommand) ProtoMessage ¶
func (*UpdateEntityCommand) ProtoMessage()
func (*UpdateEntityCommand) ProtoReflect ¶
func (x *UpdateEntityCommand) ProtoReflect() protoreflect.Message
func (*UpdateEntityCommand) Reset ¶
func (x *UpdateEntityCommand) Reset()
func (*UpdateEntityCommand) String ¶
func (x *UpdateEntityCommand) String() string