Help us shape the future of Go! Take the 2026 Go Developer Survey

clusterpb

package
v0.33.0 Latest Latest
Warning

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

Go to latest
Published: Jun 11, 2026 License: Apache-2.0 Imports: 5 Imported by: 20

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MemberlistMessage_Kind_name = map[int32]string{
		0: "STREAM",
		1: "PACKET",
	}
	MemberlistMessage_Kind_value = map[string]int32{
		"STREAM": 0,
		"PACKET": 1,
	}
)

Enum value maps for MemberlistMessage_Kind.

View Source
var File_cluster_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FullState

type FullState struct {
	Parts []*Part `protobuf:"bytes,1,rep,name=parts,proto3" json:"parts,omitempty"`
	// contains filtered or unexported fields
}

func (*FullState) Descriptor deprecated

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

Deprecated: Use FullState.ProtoReflect.Descriptor instead.

func (*FullState) GetParts added in v0.32.0

func (x *FullState) GetParts() []*Part

func (*FullState) ProtoMessage

func (*FullState) ProtoMessage()

func (*FullState) ProtoReflect added in v0.32.0

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

func (*FullState) Reset

func (x *FullState) Reset()

func (*FullState) String

func (x *FullState) String() string

type MemberlistMessage added in v0.24.0

type MemberlistMessage struct {
	Version  string                 `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Kind     MemberlistMessage_Kind `protobuf:"varint,2,opt,name=kind,proto3,enum=clusterpb.MemberlistMessage_Kind" json:"kind,omitempty"`
	FromAddr string                 `protobuf:"bytes,3,opt,name=from_addr,json=fromAddr,proto3" json:"from_addr,omitempty"`
	Msg      []byte                 `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberlistMessage) Descriptor deprecated added in v0.24.0

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

Deprecated: Use MemberlistMessage.ProtoReflect.Descriptor instead.

func (*MemberlistMessage) GetFromAddr added in v0.32.0

func (x *MemberlistMessage) GetFromAddr() string

func (*MemberlistMessage) GetKind added in v0.32.0

func (*MemberlistMessage) GetMsg added in v0.32.0

func (x *MemberlistMessage) GetMsg() []byte

func (*MemberlistMessage) GetVersion added in v0.32.0

func (x *MemberlistMessage) GetVersion() string

func (*MemberlistMessage) ProtoMessage added in v0.24.0

func (*MemberlistMessage) ProtoMessage()

func (*MemberlistMessage) ProtoReflect added in v0.32.0

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

func (*MemberlistMessage) Reset added in v0.24.0

func (x *MemberlistMessage) Reset()

func (*MemberlistMessage) String added in v0.24.0

func (x *MemberlistMessage) String() string

type MemberlistMessage_Kind added in v0.24.0

type MemberlistMessage_Kind int32
const (
	MemberlistMessage_STREAM MemberlistMessage_Kind = 0
	MemberlistMessage_PACKET MemberlistMessage_Kind = 1
)

func (MemberlistMessage_Kind) Descriptor added in v0.32.0

func (MemberlistMessage_Kind) Enum added in v0.32.0

func (MemberlistMessage_Kind) EnumDescriptor deprecated added in v0.24.0

func (MemberlistMessage_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use MemberlistMessage_Kind.Descriptor instead.

func (MemberlistMessage_Kind) Number added in v0.32.0

func (MemberlistMessage_Kind) String added in v0.24.0

func (x MemberlistMessage_Kind) String() string

func (MemberlistMessage_Kind) Type added in v0.32.0

type Part

type Part struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Part) Descriptor deprecated

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

Deprecated: Use Part.ProtoReflect.Descriptor instead.

func (*Part) GetData added in v0.32.0

func (x *Part) GetData() []byte

func (*Part) GetKey added in v0.32.0

func (x *Part) GetKey() string

func (*Part) ProtoMessage

func (*Part) ProtoMessage()

func (*Part) ProtoReflect added in v0.32.0

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

func (*Part) Reset

func (x *Part) Reset()

func (*Part) String

func (x *Part) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL