cmd_pb

package
v0.23.42 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var (
	CommandType_name = map[int32]string{
		0:  "Zero",
		1:  "CreateEntityType",
		2:  "UpdateEntityType",
		3:  "DeleteEntityType",
		4:  "DeleteTerminatorsBatchType",
		10: "SyncSnapshot",
	}
	CommandType_value = map[string]int32{
		"Zero":                       0,
		"CreateEntityType":           1,
		"UpdateEntityType":           2,
		"DeleteEntityType":           3,
		"DeleteTerminatorsBatchType": 4,
		"SyncSnapshot":               10,
	}
)

Enum value maps for CommandType.

View Source 
var File_cmd_proto protoreflect.FileDescriptor

Functions

func DecodeTags 

func DecodeTags(tags map[string]*TagValue) map[string]interface{}

func EncodeProtobuf 

func EncodeProtobuf(v TypedMessage) ([]byte, error)

EncodeProtobuf returns the encoded message, prefixed with the command type

func EncodeTags 

func EncodeTags(tags map[string]interface{}) (map[string]*TagValue, error)

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 {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	RaftIndex  uint64            `protobuf:"varint,2,opt,name=raftIndex,proto3" json:"raftIndex,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) GetAttributes added in v0.23.0 

func (x *ChangeContext) GetAttributes() map[string]string

func (*ChangeContext) GetRaftIndex added in v0.23.0 

func (x *ChangeContext) GetRaftIndex() uint64

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_DeleteTerminatorsBatchType CommandType = 4
	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 DeleteTerminatorsBatchCommand added in v0.22.76 

type DeleteTerminatorsBatchCommand struct {
	EntityIds []string       `protobuf:"bytes,1,rep,name=entityIds,proto3" json:"entityIds,omitempty"`
	Ctx       *ChangeContext `protobuf:"bytes,2,opt,name=ctx,proto3" json:"ctx,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTerminatorsBatchCommand) Descriptor deprecated added in v0.22.76 

func (*DeleteTerminatorsBatchCommand) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTerminatorsBatchCommand.ProtoReflect.Descriptor instead.

func (*DeleteTerminatorsBatchCommand) GetCommandType added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) GetCommandType() int32

func (*DeleteTerminatorsBatchCommand) GetCtx added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) GetCtx() *ChangeContext

func (*DeleteTerminatorsBatchCommand) GetEntityIds added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) GetEntityIds() []string

func (*DeleteTerminatorsBatchCommand) ProtoMessage added in v0.22.76 

func (*DeleteTerminatorsBatchCommand) ProtoMessage()

func (*DeleteTerminatorsBatchCommand) ProtoReflect added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) ProtoReflect() protoreflect.Message

func (*DeleteTerminatorsBatchCommand) Reset added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) Reset()

func (*DeleteTerminatorsBatchCommand) String added in v0.22.76 

func (x *DeleteTerminatorsBatchCommand) 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) Descriptor() ([]byte, []int)

Deprecated: Use Router.ProtoReflect.Descriptor instead.

func (*Router) GetCost 

func (x *Router) GetCost() uint32

func (*Router) GetDisabled added in v0.22.75 

func (x *Router) GetDisabled() bool

func (*Router) GetFingerprint 

func (x *Router) GetFingerprint() []byte

func (*Router) GetId 

func (x *Router) GetId() string

func (*Router) GetName 

func (x *Router) GetName() string

func (*Router) GetNoTraversal 

func (x *Router) GetNoTraversal() bool

func (*Router) GetTags 

func (x *Router) GetTags() map[string]*TagValue

func (*Router) ProtoMessage 

func (*Router) ProtoMessage()

func (*Router) ProtoReflect 

func (x *Router) ProtoReflect() protoreflect.Message

func (*Router) Reset 

func (x *Router) Reset()

func (*Router) String 

func (x *Router) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetId 

func (x *Service) GetId() string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetTags 

func (x *Service) GetTags() map[string]*TagValue

func (*Service) GetTerminatorStrategy 

func (x *Service) GetTerminatorStrategy() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TagValue.ProtoReflect.Descriptor instead.

func (*TagValue) GetBoolValue 

func (x *TagValue) GetBoolValue() bool

func (*TagValue) GetFpValue 

func (x *TagValue) GetFpValue() float64

func (*TagValue) GetNilValue 

func (x *TagValue) GetNilValue() bool

func (*TagValue) GetStringValue 

func (x *TagValue) GetStringValue() string

func (*TagValue) GetValue 

func (m *TagValue) GetValue() isTagValue_Value

func (*TagValue) ProtoMessage 

func (*TagValue) ProtoMessage()

func (*TagValue) ProtoReflect 

func (x *TagValue) ProtoReflect() protoreflect.Message

func (*TagValue) Reset 

func (x *TagValue) Reset()

func (*TagValue) String 

func (x *TagValue) String() string

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"`
	SavedPrecedence uint32               `protobuf:"varint,14,opt,name=savedPrecedence,proto3" json:"savedPrecedence,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) GetSavedPrecedence added in v0.23.34 

func (x *Terminator) GetSavedPrecedence() uint32

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 

type TypedMessage interface {
	proto.Message
	GetCommandType() int32
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.