Documentation
¶
Index ¶
- Variables
- type Age
- type Bulletin
- type Meta
- func (*Meta) Descriptor() ([]byte, []int)deprecated
- func (x *Meta) GetAvailableRoles() []string
- func (x *Meta) GetHost() string
- func (x *Meta) GetId() string
- func (x *Meta) GetName() string
- func (x *Meta) GetRoles() []string
- func (x *Meta) GetTimeStart() *timestamppb.Timestamp
- func (*Meta) ProtoMessage()
- func (x *Meta) ProtoReflect() protoreflect.Message
- func (x *Meta) Reset()
- func (x *Meta) String() string
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetResources() []*resource.Resource
- func (x *State) GetRoles() []string
- func (x *State) GetScore() float32
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- type Stream
- func (*Stream) Descriptor() ([]byte, []int)deprecated
- func (x *Stream) GetMeta() *Meta
- func (x *Stream) GetPayload() isStream_Payload
- func (x *Stream) GetState() *State
- func (*Stream) ProtoMessage()
- func (x *Stream) ProtoReflect() protoreflect.Message
- func (x *Stream) Reset()
- func (x *Stream) String() string
- type Stream_Meta
- type Stream_State
- type Sync
Constants ¶
This section is empty.
Variables ¶
View Source
var File_github_com_Compogo_cluster_model_election_proto protoreflect.FileDescriptor
View Source
var File_github_com_Compogo_cluster_model_replica_proto protoreflect.FileDescriptor
View Source
var File_github_com_Compogo_cluster_model_sync_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Age ¶
type Age struct {
Term uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
// contains filtered or unexported fields
}
func (*Age) Descriptor
deprecated
func (*Age) ProtoMessage ¶
func (*Age) ProtoMessage()
func (*Age) ProtoReflect ¶
func (x *Age) ProtoReflect() protoreflect.Message
type Bulletin ¶
type Bulletin struct {
Term uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
ReplicaId string `protobuf:"bytes,2,opt,name=ReplicaId,proto3" json:"ReplicaId,omitempty"`
// contains filtered or unexported fields
}
func (*Bulletin) Descriptor
deprecated
func (*Bulletin) GetReplicaId ¶
func (*Bulletin) ProtoMessage ¶
func (*Bulletin) ProtoMessage()
func (*Bulletin) ProtoReflect ¶
func (x *Bulletin) ProtoReflect() protoreflect.Message
type Meta ¶
type Meta 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"`
Host string `protobuf:"bytes,3,opt,name=Host,proto3" json:"Host,omitempty"`
TimeStart *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=TimeStart,proto3" json:"TimeStart,omitempty"`
AvailableRoles []string `protobuf:"bytes,5,rep,name=AvailableRoles,proto3" json:"AvailableRoles,omitempty"`
Roles []string `protobuf:"bytes,6,rep,name=Roles,proto3" json:"Roles,omitempty"`
// contains filtered or unexported fields
}
func (*Meta) Descriptor
deprecated
func (*Meta) GetAvailableRoles ¶
func (*Meta) GetTimeStart ¶
func (x *Meta) GetTimeStart() *timestamppb.Timestamp
func (*Meta) ProtoMessage ¶
func (*Meta) ProtoMessage()
func (*Meta) ProtoReflect ¶
func (x *Meta) ProtoReflect() protoreflect.Message
type State ¶
type State struct {
Score float32 `protobuf:"fixed32,1,opt,name=Score,proto3" json:"Score,omitempty"`
Resources []*resource.Resource `protobuf:"bytes,2,rep,name=Resources,proto3" json:"Resources,omitempty"`
Roles []string `protobuf:"bytes,3,rep,name=Roles,proto3" json:"Roles,omitempty"`
// contains filtered or unexported fields
}
func (*State) Descriptor
deprecated
func (*State) GetResources ¶
func (*State) ProtoMessage ¶
func (*State) ProtoMessage()
func (*State) ProtoReflect ¶
func (x *State) ProtoReflect() protoreflect.Message
type Stream ¶
type Stream struct {
// Types that are valid to be assigned to Payload:
//
// *Stream_Meta
// *Stream_State
Payload isStream_Payload `protobuf_oneof:"Payload"`
// contains filtered or unexported fields
}
func (*Stream) Descriptor
deprecated
func (*Stream) GetPayload ¶
func (x *Stream) GetPayload() isStream_Payload
func (*Stream) ProtoMessage ¶
func (*Stream) ProtoMessage()
func (*Stream) ProtoReflect ¶
func (x *Stream) ProtoReflect() protoreflect.Message
type Stream_Meta ¶
type Stream_Meta struct {
Meta *Meta `protobuf:"bytes,1,opt,name=Meta,proto3,oneof"`
}
type Stream_State ¶
type Stream_State struct {
State *State `protobuf:"bytes,2,opt,name=State,proto3,oneof"`
}
type Sync ¶
type Sync struct {
Hosts []string `protobuf:"bytes,1,rep,name=Hosts,proto3" json:"Hosts,omitempty"`
// contains filtered or unexported fields
}
func (*Sync) Descriptor
deprecated
func (*Sync) ProtoMessage ¶
func (*Sync) ProtoMessage()
func (*Sync) ProtoReflect ¶
func (x *Sync) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.