cmd_pb

package
v0.22.29 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 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",
	}
	ContentType_value = map[string]int32{
		"ContentTypeZero":       0,
		"NewLogEntryType":       2050,
		"ErrorResponseType":     2051,
		"SuccessResponseType":   2052,
		"AddPeerRequestType":    2053,
		"RemovePeerRequestType": 2054,
	}
)

Enum value maps for ContentType.

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

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 {
	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
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
)

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"`
	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) 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"`
	// 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 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.