cm

Documentation

Index

• Variables
• type ActorOf
  • func (*ActorOf) Descriptor() ([]byte, []int)
  • func (x *ActorOf) GetAbility() string
  • func (x *ActorOf) GetIdentity() string
  • func (*ActorOf) ProtoMessage()
  • func (x *ActorOf) ProtoReflect() protoreflect.Message
  • func (x *ActorOf) Reset()
  • func (x *ActorOf) String() string
• type Metadata
  • func (*Metadata) Descriptor() ([]byte, []int)
  • func (x *Metadata) GetAbilities() map[string]bool
  • func (x *Metadata) GetLaunchAt() int64
  • func (x *Metadata) GetProcessId() *prc.ProcessId
  • func (*Metadata) ProtoMessage()
  • func (x *Metadata) ProtoReflect() protoreflect.Message
  • func (x *Metadata) Reset()
  • func (x *Metadata) String() string
• type State
  • func (*State) Descriptor() ([]byte, []int)
  • func (x *State) GetUpdateAt() int64
  • func (*State) ProtoMessage()
  • func (x *State) ProtoReflect() protoreflect.Message
  • func (x *State) Reset()
  • func (x *State) String() string

Variables

var File_cm_proto protoreflect.FileDescriptor

Types

type ActorOf

type ActorOf struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Ability  string `protobuf:"bytes,2,opt,name=ability,proto3" json:"ability,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorOf) Descriptor

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

Deprecated: Use ActorOf.ProtoReflect.Descriptor instead.

func (*ActorOf) GetAbility

func (x *ActorOf) GetAbility() string

func (*ActorOf) GetIdentity

func (x *ActorOf) GetIdentity() string

func (*ActorOf) ProtoMessage

func (*ActorOf) ProtoMessage()

func (*ActorOf) ProtoReflect

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

func (*ActorOf) Reset

func (x *ActorOf) Reset()

func (*ActorOf) String

func (x *ActorOf) String() string

type Metadata

type Metadata struct {
	ProcessId *prc.ProcessId  `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"` // 节点进程 ID
	LaunchAt  int64           `protobuf:"varint,2,opt,name=launch_at,json=launchAt,proto3" json:"launch_at,omitempty"`   // 启动时间（毫秒级）
	Abilities map[string]bool ``                                                                                         // 节点提供的能力
	/* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetAbilities

func (x *Metadata) GetAbilities() map[string]bool

func (*Metadata) GetLaunchAt

func (x *Metadata) GetLaunchAt() int64

func (*Metadata) GetProcessId

func (x *Metadata) GetProcessId() *prc.ProcessId

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type State

type State struct {
	UpdateAt int64 `protobuf:"varint,1,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"` // 更新时间（毫秒级）
	// contains filtered or unexported fields
}

func (*State) Descriptor

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

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetUpdateAt

func (x *State) GetUpdateAt() int64

func (*State) ProtoMessage

func (*State) ProtoMessage()

func (*State) ProtoReflect

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

func (*State) Reset

func (x *State) Reset()

func (*State) String

func (x *State) String() string