genericsmrproto

package
v0.0.0-...-20370ad Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PROPOSE uint8 = iota
	PROPOSE_REPLY
	READ
	READ_REPLY
	PROPOSE_AND_READ
	PROPOSE_AND_READ_REPLY
	GENERIC_SMR_BEACON
	GENERIC_SMR_BEACON_REPLY
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BeTheLeaderArgs 

type BeTheLeaderArgs struct {
}

func (*BeTheLeaderArgs) BinarySize 

func (t *BeTheLeaderArgs) BinarySize() (nbytes int, sizeKnown bool)

func (*BeTheLeaderArgs) Marshal 

func (t *BeTheLeaderArgs) Marshal(wire io.Writer)

func (*BeTheLeaderArgs) Unmarshal 

func (t *BeTheLeaderArgs) Unmarshal(wire io.Reader) error

type BeTheLeaderArgsCache 

type BeTheLeaderArgsCache struct {
	// contains filtered or unexported fields
}

func NewBeTheLeaderArgsCache 

func NewBeTheLeaderArgsCache() *BeTheLeaderArgsCache

func (*BeTheLeaderArgsCache) Get 

func (p *BeTheLeaderArgsCache) Get() *BeTheLeaderArgs

func (*BeTheLeaderArgsCache) Put 

func (p *BeTheLeaderArgsCache) Put(t *BeTheLeaderArgs)

type BeTheLeaderReply 

type BeTheLeaderReply struct {
}

func (*BeTheLeaderReply) BinarySize 

func (t *BeTheLeaderReply) BinarySize() (nbytes int, sizeKnown bool)

func (*BeTheLeaderReply) Marshal 

func (t *BeTheLeaderReply) Marshal(wire io.Writer)

func (*BeTheLeaderReply) Unmarshal 

func (t *BeTheLeaderReply) Unmarshal(wire io.Reader) error

type BeTheLeaderReplyCache 

type BeTheLeaderReplyCache struct {
	// contains filtered or unexported fields
}

func NewBeTheLeaderReplyCache 

func NewBeTheLeaderReplyCache() *BeTheLeaderReplyCache

func (*BeTheLeaderReplyCache) Get 

func (p *BeTheLeaderReplyCache) Get() *BeTheLeaderReply

func (*BeTheLeaderReplyCache) Put 

func (p *BeTheLeaderReplyCache) Put(t *BeTheLeaderReply)

type Beacon 

type Beacon struct {
	Timestamp uint64
}

func (*Beacon) BinarySize 

func (t *Beacon) BinarySize() (nbytes int, sizeKnown bool)

func (*Beacon) Marshal 

func (t *Beacon) Marshal(wire io.Writer)

func (*Beacon) Unmarshal 

func (t *Beacon) Unmarshal(wire io.Reader) error

type BeaconCache 

type BeaconCache struct {
	// contains filtered or unexported fields
}

func NewBeaconCache 

func NewBeaconCache() *BeaconCache

func (*BeaconCache) Get 

func (p *BeaconCache) Get() *Beacon

func (*BeaconCache) Put 

func (p *BeaconCache) Put(t *Beacon)

type BeaconReply 

type BeaconReply struct {
	Timestamp uint64
}

func (*BeaconReply) BinarySize 

func (t *BeaconReply) BinarySize() (nbytes int, sizeKnown bool)

func (*BeaconReply) Marshal 

func (t *BeaconReply) Marshal(wire io.Writer)

func (*BeaconReply) Unmarshal 

func (t *BeaconReply) Unmarshal(wire io.Reader) error

type BeaconReplyCache 

type BeaconReplyCache struct {
	// contains filtered or unexported fields
}

func NewBeaconReplyCache 

func NewBeaconReplyCache() *BeaconReplyCache

func (*BeaconReplyCache) Get 

func (p *BeaconReplyCache) Get() *BeaconReply

func (*BeaconReplyCache) Put 

func (p *BeaconReplyCache) Put(t *BeaconReply)

type PingArgs 

type PingArgs struct {
	ActAsLeader uint8
}

func (*PingArgs) BinarySize 

func (t *PingArgs) BinarySize() (nbytes int, sizeKnown bool)

func (*PingArgs) Marshal 

func (t *PingArgs) Marshal(wire io.Writer)

func (*PingArgs) Unmarshal 

func (t *PingArgs) Unmarshal(wire io.Reader) error

type PingArgsCache 

type PingArgsCache struct {
	// contains filtered or unexported fields
}

func NewPingArgsCache 

func NewPingArgsCache() *PingArgsCache

func (*PingArgsCache) Get 

func (p *PingArgsCache) Get() *PingArgs

func (*PingArgsCache) Put 

func (p *PingArgsCache) Put(t *PingArgs)

type PingReply 

type PingReply struct {
}

func (*PingReply) BinarySize 

func (t *PingReply) BinarySize() (nbytes int, sizeKnown bool)

func (*PingReply) Marshal 

func (t *PingReply) Marshal(wire io.Writer)

func (*PingReply) Unmarshal 

func (t *PingReply) Unmarshal(wire io.Reader) error

type PingReplyCache 

type PingReplyCache struct {
	// contains filtered or unexported fields
}

func NewPingReplyCache 

func NewPingReplyCache() *PingReplyCache

func (*PingReplyCache) Get 

func (p *PingReplyCache) Get() *PingReply

func (*PingReplyCache) Put 

func (p *PingReplyCache) Put(t *PingReply)

type Propose 

type Propose struct {
	CommandId int32
	Command   state.Command
	Timestamp int64
}

func (*Propose) BinarySize 

func (t *Propose) BinarySize() (nbytes int, sizeKnown bool)

func (*Propose) Marshal 

func (t *Propose) Marshal(wire io.Writer)

func (*Propose) Unmarshal 

func (t *Propose) Unmarshal(wire io.Reader) error

type ProposeAndRead 

type ProposeAndRead struct {
	CommandId int32
	Command   state.Command
	Key       state.Key
}

func (*ProposeAndRead) BinarySize 

func (t *ProposeAndRead) BinarySize() (nbytes int, sizeKnown bool)

func (*ProposeAndRead) Marshal 

func (t *ProposeAndRead) Marshal(wire io.Writer)

func (*ProposeAndRead) Unmarshal 

func (t *ProposeAndRead) Unmarshal(wire io.Reader) error

type ProposeAndReadCache 

type ProposeAndReadCache struct {
	// contains filtered or unexported fields
}

func NewProposeAndReadCache 

func NewProposeAndReadCache() *ProposeAndReadCache

func (*ProposeAndReadCache) Get 

func (p *ProposeAndReadCache) Get() *ProposeAndRead

func (*ProposeAndReadCache) Put 

func (p *ProposeAndReadCache) Put(t *ProposeAndRead)

type ProposeAndReadReply 

type ProposeAndReadReply struct {
	OK        uint8
	CommandId int32
	Value     state.Value
}

func (*ProposeAndReadReply) BinarySize 

func (t *ProposeAndReadReply) BinarySize() (nbytes int, sizeKnown bool)

func (*ProposeAndReadReply) Marshal 

func (t *ProposeAndReadReply) Marshal(wire io.Writer)

func (*ProposeAndReadReply) Unmarshal 

func (t *ProposeAndReadReply) Unmarshal(wire io.Reader) error

type ProposeAndReadReplyCache 

type ProposeAndReadReplyCache struct {
	// contains filtered or unexported fields
}

func NewProposeAndReadReplyCache 

func NewProposeAndReadReplyCache() *ProposeAndReadReplyCache

func (*ProposeAndReadReplyCache) Get 

func (p *ProposeAndReadReplyCache) Get() *ProposeAndReadReply

func (*ProposeAndReadReplyCache) Put 

func (p *ProposeAndReadReplyCache) Put(t *ProposeAndReadReply)

type ProposeCache 

type ProposeCache struct {
	// contains filtered or unexported fields
}

func NewProposeCache 

func NewProposeCache() *ProposeCache

func (*ProposeCache) Get 

func (p *ProposeCache) Get() *Propose

func (*ProposeCache) Put 

func (p *ProposeCache) Put(t *Propose)

type ProposeReply 

type ProposeReply struct {
	OK        uint8
	CommandId int32
}

func (*ProposeReply) BinarySize 

func (t *ProposeReply) BinarySize() (nbytes int, sizeKnown bool)

func (*ProposeReply) Marshal 

func (t *ProposeReply) Marshal(wire io.Writer)

func (*ProposeReply) Unmarshal 

func (t *ProposeReply) Unmarshal(wire io.Reader) error

type ProposeReplyCache 

type ProposeReplyCache struct {
	// contains filtered or unexported fields
}

func NewProposeReplyCache 

func NewProposeReplyCache() *ProposeReplyCache

func (*ProposeReplyCache) Get 

func (p *ProposeReplyCache) Get() *ProposeReply

func (*ProposeReplyCache) Put 

func (p *ProposeReplyCache) Put(t *ProposeReply)

type ProposeReplyTS 

type ProposeReplyTS struct {
	OK        uint8
	CommandId int32
	Value     state.Value
	Timestamp int64
}

func (*ProposeReplyTS) BinarySize 

func (t *ProposeReplyTS) BinarySize() (nbytes int, sizeKnown bool)

func (*ProposeReplyTS) Marshal 

func (t *ProposeReplyTS) Marshal(wire io.Writer)

func (*ProposeReplyTS) Unmarshal 

func (t *ProposeReplyTS) Unmarshal(wire io.Reader) error

type ProposeReplyTSCache 

type ProposeReplyTSCache struct {
	// contains filtered or unexported fields
}

func NewProposeReplyTSCache 

func NewProposeReplyTSCache() *ProposeReplyTSCache

func (*ProposeReplyTSCache) Get 

func (p *ProposeReplyTSCache) Get() *ProposeReplyTS

func (*ProposeReplyTSCache) Put 

func (p *ProposeReplyTSCache) Put(t *ProposeReplyTS)

type Read 

type Read struct {
	CommandId int32
	Key       state.Key
}

func (*Read) BinarySize 

func (t *Read) BinarySize() (nbytes int, sizeKnown bool)

func (*Read) Marshal 

func (t *Read) Marshal(wire io.Writer)

func (*Read) Unmarshal 

func (t *Read) Unmarshal(wire io.Reader) error

type ReadCache 

type ReadCache struct {
	// contains filtered or unexported fields
}

func NewReadCache 

func NewReadCache() *ReadCache

func (*ReadCache) Get 

func (p *ReadCache) Get() *Read

func (*ReadCache) Put 

func (p *ReadCache) Put(t *Read)

type ReadReply 

type ReadReply struct {
	CommandId int32
	Value     state.Value
}

func (*ReadReply) BinarySize 

func (t *ReadReply) BinarySize() (nbytes int, sizeKnown bool)

func (*ReadReply) Marshal 

func (t *ReadReply) Marshal(wire io.Writer)

func (*ReadReply) Unmarshal 

func (t *ReadReply) Unmarshal(wire io.Reader) error

type ReadReplyCache 

type ReadReplyCache struct {
	// contains filtered or unexported fields
}

func NewReadReplyCache 

func NewReadReplyCache() *ReadReplyCache

func (*ReadReplyCache) Get 

func (p *ReadReplyCache) Get() *ReadReply

func (*ReadReplyCache) Put 

func (p *ReadReplyCache) Put(t *ReadReply)

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.