commonpb

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_commonpb_commonpb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClientProgress 

type ClientProgress struct {
	Progress map[string]*DeliveredReqs `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClientProgress) Descriptor deprecated 

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

Deprecated: Use ClientProgress.ProtoReflect.Descriptor instead.

func (*ClientProgress) GetProgress 

func (x *ClientProgress) GetProgress() map[string]*DeliveredReqs

func (*ClientProgress) ProtoMessage 

func (*ClientProgress) ProtoMessage()

func (*ClientProgress) ProtoReflect 

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

func (*ClientProgress) Reset 

func (x *ClientProgress) Reset()

func (*ClientProgress) String 

func (x *ClientProgress) String() string

type DeliveredReqs 

type DeliveredReqs struct {
	LowWm     uint64   `protobuf:"varint,1,opt,name=low_wm,json=lowWm,proto3" json:"low_wm,omitempty"`
	Delivered []uint64 `protobuf:"varint,2,rep,packed,name=delivered,proto3" json:"delivered,omitempty"`
	// contains filtered or unexported fields
}

func (*DeliveredReqs) Descriptor deprecated 

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

Deprecated: Use DeliveredReqs.ProtoReflect.Descriptor instead.

func (*DeliveredReqs) GetDelivered 

func (x *DeliveredReqs) GetDelivered() []uint64

func (*DeliveredReqs) GetLowWm 

func (x *DeliveredReqs) GetLowWm() uint64

func (*DeliveredReqs) ProtoMessage 

func (*DeliveredReqs) ProtoMessage()

func (*DeliveredReqs) ProtoReflect 

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

func (*DeliveredReqs) Reset 

func (x *DeliveredReqs) Reset()

func (*DeliveredReqs) String 

func (x *DeliveredReqs) String() string

type EpochConfig 

type EpochConfig struct {
	EpochNr     uint64        `protobuf:"varint,1,opt,name=epoch_nr,json=epochNr,proto3" json:"epoch_nr,omitempty"`
	FirstSn     uint64        `protobuf:"varint,2,opt,name=first_sn,json=firstSn,proto3" json:"first_sn,omitempty"`
	Length      uint64        `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	Memberships []*Membership `protobuf:"bytes,4,rep,name=memberships,proto3" json:"memberships,omitempty"`
	// contains filtered or unexported fields
}

func (*EpochConfig) Descriptor deprecated 

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

Deprecated: Use EpochConfig.ProtoReflect.Descriptor instead.

func (*EpochConfig) GetEpochNr 

func (x *EpochConfig) GetEpochNr() uint64

func (*EpochConfig) GetFirstSn 

func (x *EpochConfig) GetFirstSn() uint64

func (*EpochConfig) GetLength 

func (x *EpochConfig) GetLength() uint64

func (*EpochConfig) GetMemberships 

func (x *EpochConfig) GetMemberships() []*Membership

func (*EpochConfig) ProtoMessage 

func (*EpochConfig) ProtoMessage()

func (*EpochConfig) ProtoReflect 

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

func (*EpochConfig) Reset 

func (x *EpochConfig) Reset()

func (*EpochConfig) String 

func (x *EpochConfig) String() string

type EpochData 

type EpochData struct {
	EpochConfig        *EpochConfig    `protobuf:"bytes,1,opt,name=epoch_config,json=epochConfig,proto3" json:"epoch_config,omitempty"`
	ClientProgress     *ClientProgress `protobuf:"bytes,2,opt,name=client_progress,json=clientProgress,proto3" json:"client_progress,omitempty"`
	LeaderPolicy       []byte          `protobuf:"bytes,3,opt,name=leader_policy,json=leaderPolicy,proto3" json:"leader_policy,omitempty"`
	PreviousMembership *Membership     `protobuf:"bytes,4,opt,name=previous_membership,json=previousMembership,proto3" json:"previous_membership,omitempty"`
	// contains filtered or unexported fields
}

func (*EpochData) Descriptor deprecated 

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

Deprecated: Use EpochData.ProtoReflect.Descriptor instead.

func (*EpochData) GetClientProgress 

func (x *EpochData) GetClientProgress() *ClientProgress

func (*EpochData) GetEpochConfig 

func (x *EpochData) GetEpochConfig() *EpochConfig

func (*EpochData) GetLeaderPolicy added in v0.2.0 

func (x *EpochData) GetLeaderPolicy() []byte

func (*EpochData) GetPreviousMembership added in v0.2.2 

func (x *EpochData) GetPreviousMembership() *Membership

func (*EpochData) ProtoMessage 

func (*EpochData) ProtoMessage()

func (*EpochData) ProtoReflect 

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

func (*EpochData) Reset 

func (x *EpochData) Reset()

func (*EpochData) String 

func (x *EpochData) String() string

type HashData 

type HashData struct {
	Data [][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*HashData) Descriptor deprecated 

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

Deprecated: Use HashData.ProtoReflect.Descriptor instead.

func (*HashData) GetData 

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

func (*HashData) ProtoMessage 

func (*HashData) ProtoMessage()

func (*HashData) ProtoReflect 

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

func (*HashData) Reset 

func (x *HashData) Reset()

func (*HashData) String 

func (x *HashData) String() string

type Membership 

type Membership struct {
	Membership map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Membership) Descriptor deprecated 

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

Deprecated: Use Membership.ProtoReflect.Descriptor instead.

func (*Membership) GetMembership 

func (x *Membership) GetMembership() map[string]string

func (*Membership) ProtoMessage 

func (*Membership) ProtoMessage()

func (*Membership) ProtoReflect 

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

func (*Membership) Reset 

func (x *Membership) Reset()

func (*Membership) String 

func (x *Membership) String() string

type StateSnapshot 

type StateSnapshot struct {
	AppData   []byte     `protobuf:"bytes,1,opt,name=app_data,json=appData,proto3" json:"app_data,omitempty"`
	EpochData *EpochData `protobuf:"bytes,2,opt,name=epoch_data,json=epochData,proto3" json:"epoch_data,omitempty"`
	// contains filtered or unexported fields
}

func (*StateSnapshot) Descriptor deprecated 

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

Deprecated: Use StateSnapshot.ProtoReflect.Descriptor instead.

func (*StateSnapshot) GetAppData 

func (x *StateSnapshot) GetAppData() []byte

func (*StateSnapshot) GetEpochData 

func (x *StateSnapshot) GetEpochData() *EpochData

func (*StateSnapshot) ProtoMessage 

func (*StateSnapshot) ProtoMessage()

func (*StateSnapshot) ProtoReflect 

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

func (*StateSnapshot) Reset 

func (x *StateSnapshot) Reset()

func (*StateSnapshot) String 

func (x *StateSnapshot) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.