gossip

package
v1.2.4 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGossip        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGossip          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGossip = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Operation_name = map[int32]string{
	0: "Unknown",
	1: "Set",
	2: "Delete",
}
View Source 
var Operation_value = map[string]int32{
	"Unknown": 0,
	"Set":     1,
	"Delete":  2,
}

Functions

func NewItem added in v1.2.0 

func NewItem[T any]() *T

Types

type CacheKeyItem 

type CacheKeyItem struct {
	Operation            Operation      `protobuf:"varint,1,opt,name=Operation,proto3,enum=gossip.Operation" json:"Operation,omitempty"`
	CacheKey             query.CacheKey `protobuf:"bytes,2,opt,name=CacheKey,proto3" json:"CacheKey"`
	TargetAddress        string         `protobuf:"bytes,3,opt,name=TargetAddress,proto3" json:"TargetAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

CacheKeyItem is the item of cache key for data in file-service.

func (*CacheKeyItem) Descriptor 

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

func (*CacheKeyItem) GetCacheKey 

func (m *CacheKeyItem) GetCacheKey() query.CacheKey

func (*CacheKeyItem) GetOperation 

func (m *CacheKeyItem) GetOperation() Operation

func (*CacheKeyItem) GetTargetAddress 

func (m *CacheKeyItem) GetTargetAddress() string

func (*CacheKeyItem) Marshal 

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

func (*CacheKeyItem) MarshalTo 

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

func (*CacheKeyItem) MarshalToSizedBuffer 

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

func (*CacheKeyItem) ProtoMessage 

func (*CacheKeyItem) ProtoMessage()

func (*CacheKeyItem) Reset 

func (m *CacheKeyItem) Reset()

func (*CacheKeyItem) Size 

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

func (*CacheKeyItem) String 

func (m *CacheKeyItem) String() string

func (*CacheKeyItem) Unmarshal 

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

func (*CacheKeyItem) XXX_DiscardUnknown 

func (m *CacheKeyItem) XXX_DiscardUnknown()

func (*CacheKeyItem) XXX_Marshal 

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

func (*CacheKeyItem) XXX_Merge 

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

func (*CacheKeyItem) XXX_Size 

func (m *CacheKeyItem) XXX_Size() int

func (*CacheKeyItem) XXX_Unmarshal 

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

type CommonItem added in v1.2.0 

type CommonItem struct {
	Operation     Operation `protobuf:"varint,1,opt,name=Operation,proto3,enum=gossip.Operation" json:"Operation,omitempty"`
	TargetAddress string    `protobuf:"bytes,2,opt,name=TargetAddress,proto3" json:"TargetAddress,omitempty"`
	// Types that are valid to be assigned to Key:
	//	*CommonItem_CacheKey
	//	*CommonItem_StatsInfoKey
	Key                  isCommonItem_Key `protobuf_oneof:"Key"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CommonItem) Descriptor added in v1.2.0 

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

func (*CommonItem) GetCacheKey added in v1.2.0 

func (m *CommonItem) GetCacheKey() *query.CacheKey

func (*CommonItem) GetKey added in v1.2.0 

func (m *CommonItem) GetKey() isCommonItem_Key

func (*CommonItem) GetOperation added in v1.2.0 

func (m *CommonItem) GetOperation() Operation

func (*CommonItem) GetStatsInfoKey added in v1.2.0 

func (m *CommonItem) GetStatsInfoKey() *statsinfo.StatsInfoKey

func (*CommonItem) GetTargetAddress added in v1.2.0 

func (m *CommonItem) GetTargetAddress() string

func (*CommonItem) Marshal added in v1.2.0 

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

func (*CommonItem) MarshalTo added in v1.2.0 

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

func (*CommonItem) MarshalToSizedBuffer added in v1.2.0 

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

func (*CommonItem) ProtoMessage added in v1.2.0 

func (*CommonItem) ProtoMessage()

func (*CommonItem) Reset added in v1.2.0 

func (m *CommonItem) Reset()

func (*CommonItem) Size added in v1.2.0 

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

func (*CommonItem) String added in v1.2.0 

func (m *CommonItem) String() string

func (*CommonItem) Unmarshal added in v1.2.0 

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

func (*CommonItem) XXX_DiscardUnknown added in v1.2.0 

func (m *CommonItem) XXX_DiscardUnknown()

func (*CommonItem) XXX_Marshal added in v1.2.0 

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

func (*CommonItem) XXX_Merge added in v1.2.0 

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

func (*CommonItem) XXX_OneofWrappers added in v1.2.0 

func (*CommonItem) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CommonItem) XXX_Size added in v1.2.0 

func (m *CommonItem) XXX_Size() int

func (*CommonItem) XXX_Unmarshal added in v1.2.0 

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

type CommonItem_CacheKey added in v1.2.0 

type CommonItem_CacheKey struct {
	CacheKey *query.CacheKey `protobuf:"bytes,3,opt,name=CacheKey,proto3,oneof" json:"CacheKey,omitempty"`
}

func (*CommonItem_CacheKey) MarshalTo added in v1.2.0 

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

func (*CommonItem_CacheKey) MarshalToSizedBuffer added in v1.2.0 

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

func (*CommonItem_CacheKey) Size added in v1.2.0 

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

type CommonItem_StatsInfoKey added in v1.2.0 

type CommonItem_StatsInfoKey struct {
	StatsInfoKey *statsinfo.StatsInfoKey `protobuf:"bytes,4,opt,name=StatsInfoKey,proto3,oneof" json:"StatsInfoKey,omitempty"`
}

func (*CommonItem_StatsInfoKey) MarshalTo added in v1.2.0 

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

func (*CommonItem_StatsInfoKey) MarshalToSizedBuffer added in v1.2.0 

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

func (*CommonItem_StatsInfoKey) Size added in v1.2.0 

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

type GossipData added in v1.2.0 

type GossipData struct {
	// Types that are valid to be assigned to Data:
	//	*GossipData_CacheKeyItem
	//	*GossipData_StatsInfoKeyItem
	Data                 isGossipData_Data `protobuf_oneof:"Data"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GossipData) Descriptor added in v1.2.0 

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

func (*GossipData) GetCacheKeyItem added in v1.2.0 

func (m *GossipData) GetCacheKeyItem() *CacheKeyItem

func (*GossipData) GetData added in v1.2.0 

func (m *GossipData) GetData() isGossipData_Data

func (*GossipData) GetStatsInfoKeyItem added in v1.2.0 

func (m *GossipData) GetStatsInfoKeyItem() *StatsInfoKeyItem

func (*GossipData) Marshal added in v1.2.0 

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

func (*GossipData) MarshalTo added in v1.2.0 

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

func (*GossipData) MarshalToSizedBuffer added in v1.2.0 

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

func (*GossipData) ProtoMessage added in v1.2.0 

func (*GossipData) ProtoMessage()

func (*GossipData) Reset added in v1.2.0 

func (m *GossipData) Reset()

func (*GossipData) Size added in v1.2.0 

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

func (*GossipData) String added in v1.2.0 

func (m *GossipData) String() string

func (*GossipData) Unmarshal added in v1.2.0 

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

func (*GossipData) XXX_DiscardUnknown added in v1.2.0 

func (m *GossipData) XXX_DiscardUnknown()

func (*GossipData) XXX_Marshal added in v1.2.0 

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

func (*GossipData) XXX_Merge added in v1.2.0 

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

func (*GossipData) XXX_OneofWrappers added in v1.2.0 

func (*GossipData) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GossipData) XXX_Size added in v1.2.0 

func (m *GossipData) XXX_Size() int

func (*GossipData) XXX_Unmarshal added in v1.2.0 

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

type GossipData_CacheKeyItem added in v1.2.0 

type GossipData_CacheKeyItem struct {
	CacheKeyItem *CacheKeyItem `protobuf:"bytes,1,opt,name=CacheKeyItem,proto3,oneof" json:"CacheKeyItem,omitempty"`
}

func (*GossipData_CacheKeyItem) MarshalTo added in v1.2.0 

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

func (*GossipData_CacheKeyItem) MarshalToSizedBuffer added in v1.2.0 

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

func (*GossipData_CacheKeyItem) Size added in v1.2.0 

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

type GossipData_StatsInfoKeyItem added in v1.2.0 

type GossipData_StatsInfoKeyItem struct {
	StatsInfoKeyItem *StatsInfoKeyItem `protobuf:"bytes,2,opt,name=StatsInfoKeyItem,proto3,oneof" json:"StatsInfoKeyItem,omitempty"`
}

func (*GossipData_StatsInfoKeyItem) MarshalTo added in v1.2.0 

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

func (*GossipData_StatsInfoKeyItem) MarshalToSizedBuffer added in v1.2.0 

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

func (*GossipData_StatsInfoKeyItem) Size added in v1.2.0 

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

type LocalState added in v1.2.0 

type LocalState struct {
	CacheKeys            query.CacheKeys         `protobuf:"bytes,1,opt,name=CacheKeys,proto3" json:"CacheKeys"`
	StatsInfoKeys        statsinfo.StatsInfoKeys `protobuf:"bytes,2,opt,name=StatsInfoKeys,proto3" json:"StatsInfoKeys"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*LocalState) Descriptor added in v1.2.0 

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

func (*LocalState) GetCacheKeys added in v1.2.0 

func (m *LocalState) GetCacheKeys() query.CacheKeys

func (*LocalState) GetStatsInfoKeys added in v1.2.0 

func (m *LocalState) GetStatsInfoKeys() statsinfo.StatsInfoKeys

func (*LocalState) Marshal added in v1.2.0 

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

func (*LocalState) MarshalTo added in v1.2.0 

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

func (*LocalState) MarshalToSizedBuffer added in v1.2.0 

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

func (*LocalState) ProtoMessage added in v1.2.0 

func (*LocalState) ProtoMessage()

func (*LocalState) Reset added in v1.2.0 

func (m *LocalState) Reset()

func (*LocalState) Size added in v1.2.0 

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

func (*LocalState) String added in v1.2.0 

func (m *LocalState) String() string

func (*LocalState) Unmarshal added in v1.2.0 

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

func (*LocalState) XXX_DiscardUnknown added in v1.2.0 

func (m *LocalState) XXX_DiscardUnknown()

func (*LocalState) XXX_Marshal added in v1.2.0 

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

func (*LocalState) XXX_Merge added in v1.2.0 

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

func (*LocalState) XXX_Size added in v1.2.0 

func (m *LocalState) XXX_Size() int

func (*LocalState) XXX_Unmarshal added in v1.2.0 

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

type Operation 

type Operation int32
const (
	Operation_Unknown Operation = 0
	Operation_Set     Operation = 1
	Operation_Delete  Operation = 2
)

func (Operation) EnumDescriptor 

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

func (Operation) String 

func (x Operation) String() string

type StatsInfoKeyItem added in v1.2.0 

type StatsInfoKeyItem struct {
	Operation            Operation              `protobuf:"varint,1,opt,name=Operation,proto3,enum=gossip.Operation" json:"Operation,omitempty"`
	StatsInfoKey         statsinfo.StatsInfoKey `protobuf:"bytes,2,opt,name=StatsInfoKey,proto3" json:"StatsInfoKey"`
	TargetAddress        string                 `protobuf:"bytes,3,opt,name=TargetAddress,proto3" json:"TargetAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StatsInfoKeyItem) Descriptor added in v1.2.0 

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

func (*StatsInfoKeyItem) GetOperation added in v1.2.0 

func (m *StatsInfoKeyItem) GetOperation() Operation

func (*StatsInfoKeyItem) GetStatsInfoKey added in v1.2.0 

func (m *StatsInfoKeyItem) GetStatsInfoKey() statsinfo.StatsInfoKey

func (*StatsInfoKeyItem) GetTargetAddress added in v1.2.0 

func (m *StatsInfoKeyItem) GetTargetAddress() string

func (*StatsInfoKeyItem) Marshal added in v1.2.0 

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

func (*StatsInfoKeyItem) MarshalTo added in v1.2.0 

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

func (*StatsInfoKeyItem) MarshalToSizedBuffer added in v1.2.0 

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

func (*StatsInfoKeyItem) ProtoMessage added in v1.2.0 

func (*StatsInfoKeyItem) ProtoMessage()

func (*StatsInfoKeyItem) Reset added in v1.2.0 

func (m *StatsInfoKeyItem) Reset()

func (*StatsInfoKeyItem) Size added in v1.2.0 

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

func (*StatsInfoKeyItem) String added in v1.2.0 

func (m *StatsInfoKeyItem) String() string

func (*StatsInfoKeyItem) Unmarshal added in v1.2.0 

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

func (*StatsInfoKeyItem) XXX_DiscardUnknown added in v1.2.0 

func (m *StatsInfoKeyItem) XXX_DiscardUnknown()

func (*StatsInfoKeyItem) XXX_Marshal added in v1.2.0 

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

func (*StatsInfoKeyItem) XXX_Merge added in v1.2.0 

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

func (*StatsInfoKeyItem) XXX_Size added in v1.2.0 

func (m *StatsInfoKeyItem) XXX_Size() int

func (*StatsInfoKeyItem) XXX_Unmarshal added in v1.2.0 

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

type TargetState added in v1.2.0 

type TargetState struct {
	Data                 map[string]*LocalState `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*TargetState) Descriptor added in v1.2.0 

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

func (*TargetState) GetData added in v1.2.0 

func (m *TargetState) GetData() map[string]*LocalState

func (*TargetState) Marshal added in v1.2.0 

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

func (*TargetState) MarshalTo added in v1.2.0 

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

func (*TargetState) MarshalToSizedBuffer added in v1.2.0 

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

func (*TargetState) ProtoMessage added in v1.2.0 

func (*TargetState) ProtoMessage()

func (*TargetState) Reset added in v1.2.0 

func (m *TargetState) Reset()

func (*TargetState) Size added in v1.2.0 

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

func (*TargetState) String added in v1.2.0 

func (m *TargetState) String() string

func (*TargetState) Unmarshal added in v1.2.0 

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

func (*TargetState) XXX_DiscardUnknown added in v1.2.0 

func (m *TargetState) XXX_DiscardUnknown()

func (*TargetState) XXX_Marshal added in v1.2.0 

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

func (*TargetState) XXX_Merge added in v1.2.0 

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

func (*TargetState) XXX_Size added in v1.2.0 

func (m *TargetState) XXX_Size() int

func (*TargetState) XXX_Unmarshal added in v1.2.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.