clusterpb

package
v0.32.0 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 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