cluster

Documentation

Index

• Variables
• type HostInfo
  • func (*HostInfo) Descriptor() ([]byte, []int)
  • func (this *HostInfo) Equal(that interface{}) bool
  • func (m *HostInfo) GetIdentity() string
  • func (this *HostInfo) GoString() string
  • func (m *HostInfo) Marshal() (dAtA []byte, err error)
  • func (m *HostInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *HostInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*HostInfo) ProtoMessage()
  • func (m *HostInfo) Reset()
  • func (m *HostInfo) Size() (n int)
  • func (this *HostInfo) String() string
  • func (m *HostInfo) Unmarshal(dAtA []byte) error
  • func (m *HostInfo) XXX_DiscardUnknown()
  • func (m *HostInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *HostInfo) XXX_Merge(src proto.Message)
  • func (m *HostInfo) XXX_Size() int
  • func (m *HostInfo) XXX_Unmarshal(b []byte) error
• type MembershipInfo
  • func (*MembershipInfo) Descriptor() ([]byte, []int)
  • func (this *MembershipInfo) Equal(that interface{}) bool
  • func (m *MembershipInfo) GetCurrentHost() *HostInfo
  • func (m *MembershipInfo) GetReachableMembers() []string
  • func (m *MembershipInfo) GetRings() []*RingInfo
  • func (this *MembershipInfo) GoString() string
  • func (m *MembershipInfo) Marshal() (dAtA []byte, err error)
  • func (m *MembershipInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *MembershipInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MembershipInfo) ProtoMessage()
  • func (m *MembershipInfo) Reset()
  • func (m *MembershipInfo) Size() (n int)
  • func (this *MembershipInfo) String() string
  • func (m *MembershipInfo) Unmarshal(dAtA []byte) error
  • func (m *MembershipInfo) XXX_DiscardUnknown()
  • func (m *MembershipInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MembershipInfo) XXX_Merge(src proto.Message)
  • func (m *MembershipInfo) XXX_Size() int
  • func (m *MembershipInfo) XXX_Unmarshal(b []byte) error
• type RingInfo
  • func (*RingInfo) Descriptor() ([]byte, []int)
  • func (this *RingInfo) Equal(that interface{}) bool
  • func (m *RingInfo) GetMemberCount() int32
  • func (m *RingInfo) GetMembers() []*HostInfo
  • func (m *RingInfo) GetRole() string
  • func (this *RingInfo) GoString() string
  • func (m *RingInfo) Marshal() (dAtA []byte, err error)
  • func (m *RingInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *RingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RingInfo) ProtoMessage()
  • func (m *RingInfo) Reset()
  • func (m *RingInfo) Size() (n int)
  • func (this *RingInfo) String() string
  • func (m *RingInfo) Unmarshal(dAtA []byte) error
  • func (m *RingInfo) XXX_DiscardUnknown()
  • func (m *RingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RingInfo) XXX_Merge(src proto.Message)
  • func (m *RingInfo) XXX_Size() int
  • func (m *RingInfo) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Types

type HostInfo

type HostInfo struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*HostInfo) Descriptor

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

func (*HostInfo) Equal

func (this *HostInfo) Equal(that interface{}) bool

func (*HostInfo) GetIdentity

func (m *HostInfo) GetIdentity() string

func (*HostInfo) GoString

func (this *HostInfo) GoString() string

func (*HostInfo) Marshal

func (m *HostInfo) Marshal() (dAtA []byte, err error)

func (*HostInfo) MarshalTo

func (m *HostInfo) MarshalTo(dAtA []byte) (int, error)

func (*HostInfo) MarshalToSizedBuffer

func (m *HostInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HostInfo) ProtoMessage

func (*HostInfo) ProtoMessage()

func (*HostInfo) Reset

func (m *HostInfo) Reset()

func (*HostInfo) Size

func (m *HostInfo) Size() (n int)

func (*HostInfo) String

func (this *HostInfo) String() string

func (*HostInfo) Unmarshal

func (m *HostInfo) Unmarshal(dAtA []byte) error

func (*HostInfo) XXX_DiscardUnknown

func (m *HostInfo) XXX_DiscardUnknown()

func (*HostInfo) XXX_Marshal

func (m *HostInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostInfo) XXX_Merge

func (m *HostInfo) XXX_Merge(src proto.Message)

func (*HostInfo) XXX_Size

func (m *HostInfo) XXX_Size() int

func (*HostInfo) XXX_Unmarshal

func (m *HostInfo) XXX_Unmarshal(b []byte) error

type MembershipInfo

type MembershipInfo struct {
	CurrentHost      *HostInfo   `protobuf:"bytes,1,opt,name=current_host,json=currentHost,proto3" json:"current_host,omitempty"`
	ReachableMembers []string    `protobuf:"bytes,2,rep,name=reachable_members,json=reachableMembers,proto3" json:"reachable_members,omitempty"`
	Rings            []*RingInfo `protobuf:"bytes,3,rep,name=rings,proto3" json:"rings,omitempty"`
}

func (*MembershipInfo) Descriptor

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

func (*MembershipInfo) Equal

func (this *MembershipInfo) Equal(that interface{}) bool

func (*MembershipInfo) GetCurrentHost

func (m *MembershipInfo) GetCurrentHost() *HostInfo

func (*MembershipInfo) GetReachableMembers

func (m *MembershipInfo) GetReachableMembers() []string

func (*MembershipInfo) GetRings

func (m *MembershipInfo) GetRings() []*RingInfo

func (*MembershipInfo) GoString

func (this *MembershipInfo) GoString() string

func (*MembershipInfo) Marshal

func (m *MembershipInfo) Marshal() (dAtA []byte, err error)

func (*MembershipInfo) MarshalTo

func (m *MembershipInfo) MarshalTo(dAtA []byte) (int, error)

func (*MembershipInfo) MarshalToSizedBuffer

func (m *MembershipInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MembershipInfo) ProtoMessage

func (*MembershipInfo) ProtoMessage()

func (*MembershipInfo) Reset

func (m *MembershipInfo) Reset()

func (*MembershipInfo) Size

func (m *MembershipInfo) Size() (n int)

func (*MembershipInfo) String

func (this *MembershipInfo) String() string

func (*MembershipInfo) Unmarshal

func (m *MembershipInfo) Unmarshal(dAtA []byte) error

func (*MembershipInfo) XXX_DiscardUnknown

func (m *MembershipInfo) XXX_DiscardUnknown()

func (*MembershipInfo) XXX_Marshal

func (m *MembershipInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MembershipInfo) XXX_Merge

func (m *MembershipInfo) XXX_Merge(src proto.Message)

func (*MembershipInfo) XXX_Size

func (m *MembershipInfo) XXX_Size() int

func (*MembershipInfo) XXX_Unmarshal

func (m *MembershipInfo) XXX_Unmarshal(b []byte) error

type RingInfo

type RingInfo struct {
	Role        string      `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	MemberCount int32       `protobuf:"varint,2,opt,name=member_count,json=memberCount,proto3" json:"member_count,omitempty"`
	Members     []*HostInfo `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
}

func (*RingInfo) Descriptor

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

func (*RingInfo) Equal

func (this *RingInfo) Equal(that interface{}) bool

func (*RingInfo) GetMemberCount

func (m *RingInfo) GetMemberCount() int32

func (*RingInfo) GetMembers

func (m *RingInfo) GetMembers() []*HostInfo

func (*RingInfo) GetRole

func (m *RingInfo) GetRole() string

func (*RingInfo) GoString

func (this *RingInfo) GoString() string

func (*RingInfo) Marshal

func (m *RingInfo) Marshal() (dAtA []byte, err error)

func (*RingInfo) MarshalTo

func (m *RingInfo) MarshalTo(dAtA []byte) (int, error)

func (*RingInfo) MarshalToSizedBuffer

func (m *RingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RingInfo) ProtoMessage

func (*RingInfo) ProtoMessage()

func (*RingInfo) Reset

func (m *RingInfo) Reset()

func (*RingInfo) Size

func (m *RingInfo) Size() (n int)

func (*RingInfo) String

func (this *RingInfo) String() string

func (*RingInfo) Unmarshal

func (m *RingInfo) Unmarshal(dAtA []byte) error

func (*RingInfo) XXX_DiscardUnknown

func (m *RingInfo) XXX_DiscardUnknown()

func (*RingInfo) XXX_Marshal

func (m *RingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RingInfo) XXX_Merge

func (m *RingInfo) XXX_Merge(src proto.Message)

func (*RingInfo) XXX_Size

func (m *RingInfo) XXX_Size() int

func (*RingInfo) XXX_Unmarshal

func (m *RingInfo) XXX_Unmarshal(b []byte) error