latentcopilotproto

package
v0.0.0-...-7c35310 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NONE int8 = iota
	PREACCEPTED
	PREACCEPTED_EQ
	ACCEPTED
	COMMITTED
	EXECUTED
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Accept 

type Accept struct {
	LeaderId  int32
	Replica   int32
	Instance  int32
	Ballot    int32
	ViewId    int32
	Command   []state.Command
	Deps      []int32
	DepViewId int32 /*View Id of dependency. Used for null dep checking*/
}

func (*Accept) BinarySize 

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

func (*Accept) Marshal 

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

func (*Accept) New 

func (t *Accept) New() fastrpc.Serializable

func (*Accept) Unmarshal 

func (t *Accept) Unmarshal(rr io.Reader) error

type AcceptCache 

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

func NewAcceptCache 

func NewAcceptCache() *AcceptCache

func (*AcceptCache) Get 

func (p *AcceptCache) Get() *Accept

func (*AcceptCache) Put 

func (p *AcceptCache) Put(t *Accept)

type AcceptReply 

type AcceptReply struct {
	Replica  int32
	Instance int32
	OK       uint8
	ViewId   int32
	Ballot   int32
	DepSeen  uint8
}

func (*AcceptReply) BinarySize 

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

func (*AcceptReply) Marshal 

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

func (*AcceptReply) New 

func (t *AcceptReply) New() fastrpc.Serializable

func (*AcceptReply) Unmarshal 

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

type AcceptReplyCache 

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

func NewAcceptReplyCache 

func NewAcceptReplyCache() *AcceptReplyCache

func (*AcceptReplyCache) Get 

func (p *AcceptReplyCache) Get() *AcceptReply

func (*AcceptReplyCache) Put 

func (p *AcceptReplyCache) Put(t *AcceptReply)

type Commit 

type Commit struct {
	LeaderId    int32
	Replica     int32
	Instance    int32
	Command     []state.Command
	Deps        []int32
	NullDepSafe uint8
	DepViewId   int32
}

func (*Commit) BinarySize 

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

func (*Commit) Marshal 

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

func (*Commit) New 

func (t *Commit) New() fastrpc.Serializable

func (*Commit) Unmarshal 

func (t *Commit) Unmarshal(rr io.Reader) error

type CommitCache 

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

func NewCommitCache 

func NewCommitCache() *CommitCache

func (*CommitCache) Get 

func (p *CommitCache) Get() *Commit

func (*CommitCache) Put 

func (p *CommitCache) Put(t *Commit)

type CommitShort 

type CommitShort struct {
	LeaderId    int32
	Replica     int32
	Instance    int32
	Count       int32
	Deps        []int32
	NullDepSafe uint8
	DepViewId   int32
}

func (*CommitShort) BinarySize 

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

func (*CommitShort) Marshal 

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

func (*CommitShort) New 

func (t *CommitShort) New() fastrpc.Serializable

func (*CommitShort) Unmarshal 

func (t *CommitShort) Unmarshal(rr io.Reader) error

type CommitShortCache 

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

func NewCommitShortCache 

func NewCommitShortCache() *CommitShortCache

func (*CommitShortCache) Get 

func (p *CommitShortCache) Get() *CommitShort

func (*CommitShortCache) Put 

func (p *CommitShortCache) Put(t *CommitShort)

type PreAccept 

type PreAccept struct {
	LeaderId  int32
	Replica   int32
	Instance  int32
	ViewId    int32
	Ballot    int32
	Command   []state.Command
	Deps      []int32
	DepViewId int32 /*View Id of dependency. Used for null dep checking*/
}

func (*PreAccept) BinarySize 

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

func (*PreAccept) Marshal 

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

func (*PreAccept) New 

func (t *PreAccept) New() fastrpc.Serializable

func (*PreAccept) Unmarshal 

func (t *PreAccept) Unmarshal(rr io.Reader) error

type PreAcceptCache 

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

func NewPreAcceptCache 

func NewPreAcceptCache() *PreAcceptCache

func (*PreAcceptCache) Get 

func (p *PreAcceptCache) Get() *PreAccept

func (*PreAcceptCache) Put 

func (p *PreAcceptCache) Put(t *PreAccept)

type PreAcceptOK 

type PreAcceptOK struct {
	Instance int32
}

func (*PreAcceptOK) BinarySize 

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

func (*PreAcceptOK) Marshal 

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

func (*PreAcceptOK) New 

func (t *PreAcceptOK) New() fastrpc.Serializable

func (*PreAcceptOK) Unmarshal 

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

type PreAcceptOKCache 

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

func NewPreAcceptOKCache 

func NewPreAcceptOKCache() *PreAcceptOKCache

func (*PreAcceptOKCache) Get 

func (p *PreAcceptOKCache) Get() *PreAcceptOK

func (*PreAcceptOKCache) Put 

func (p *PreAcceptOKCache) Put(t *PreAcceptOK)

type PreAcceptReply 

type PreAcceptReply struct {
	Replica       int32
	Instance      int32
	OK            uint8
	ViewId        int32
	Ballot        int32
	Deps          []int32
	CommittedDeps []int32
	DepSeen       uint8
	CmdCommitted  uint8
}

func (*PreAcceptReply) BinarySize 

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

func (*PreAcceptReply) Marshal 

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

func (*PreAcceptReply) New 

func (t *PreAcceptReply) New() fastrpc.Serializable

func (*PreAcceptReply) Unmarshal 

func (t *PreAcceptReply) Unmarshal(rr io.Reader) error

type PreAcceptReplyCache 

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

func NewPreAcceptReplyCache 

func NewPreAcceptReplyCache() *PreAcceptReplyCache

func (*PreAcceptReplyCache) Get 

func (p *PreAcceptReplyCache) Get() *PreAcceptReply

func (*PreAcceptReplyCache) Put 

func (p *PreAcceptReplyCache) Put(t *PreAcceptReply)

type Prepare 

type Prepare struct {
	LeaderId int32
	Replica  int32
	Instance int32
	ViewId   int32
	Ballot   int32
}

func (*Prepare) BinarySize 

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

func (*Prepare) Marshal 

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

func (*Prepare) New 

func (t *Prepare) New() fastrpc.Serializable

func (*Prepare) Unmarshal 

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

type PrepareCache 

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

func NewPrepareCache 

func NewPrepareCache() *PrepareCache

func (*PrepareCache) Get 

func (p *PrepareCache) Get() *Prepare

func (*PrepareCache) Put 

func (p *PrepareCache) Put(t *Prepare)

type PrepareReply 

type PrepareReply struct {
	AcceptorId  int32
	Replica     int32
	Instance    int32
	OK          uint8
	ViewId      int32
	Ballot      int32
	Status      int8
	Command     []state.Command
	Deps        []int32
	NullDepSafe uint8
	DepViewId   int32
}

func (*PrepareReply) BinarySize 

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

func (*PrepareReply) Marshal 

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

func (*PrepareReply) New 

func (t *PrepareReply) New() fastrpc.Serializable

func (*PrepareReply) Unmarshal 

func (t *PrepareReply) Unmarshal(rr io.Reader) error

type PrepareReplyCache 

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

func NewPrepareReplyCache 

func NewPrepareReplyCache() *PrepareReplyCache

func (*PrepareReplyCache) Get 

func (p *PrepareReplyCache) Get() *PrepareReply

func (*PrepareReplyCache) Put 

func (p *PrepareReplyCache) Put(t *PrepareReply)

type TryPreAccept 

type TryPreAccept struct {
	LeaderId int32
	Replica  int32
	Instance int32
	Ballot   int32
	Command  []state.Command
	Deps     []int32
}

func (*TryPreAccept) BinarySize 

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

func (*TryPreAccept) Marshal 

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

func (*TryPreAccept) New 

func (t *TryPreAccept) New() fastrpc.Serializable

func (*TryPreAccept) Unmarshal 

func (t *TryPreAccept) Unmarshal(rr io.Reader) error

type TryPreAcceptCache 

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

func NewTryPreAcceptCache 

func NewTryPreAcceptCache() *TryPreAcceptCache

func (*TryPreAcceptCache) Get 

func (p *TryPreAcceptCache) Get() *TryPreAccept

func (*TryPreAcceptCache) Put 

func (p *TryPreAcceptCache) Put(t *TryPreAccept)

type TryPreAcceptReply 

type TryPreAcceptReply struct {
	AcceptorId       int32
	Replica          int32
	Instance         int32
	OK               uint8
	Ballot           int32
	ConflictReplica  int32
	ConflictInstance int32
	ConflictStatus   int8
}

func (*TryPreAcceptReply) BinarySize 

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

func (*TryPreAcceptReply) Marshal 

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

func (*TryPreAcceptReply) New 

func (t *TryPreAcceptReply) New() fastrpc.Serializable

func (*TryPreAcceptReply) Unmarshal 

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

type TryPreAcceptReplyCache 

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

func NewTryPreAcceptReplyCache 

func NewTryPreAcceptReplyCache() *TryPreAcceptReplyCache

func (*TryPreAcceptReplyCache) Get 

func (p *TryPreAcceptReplyCache) Get() *TryPreAcceptReply

func (*TryPreAcceptReplyCache) Put 

func (p *TryPreAcceptReplyCache) Put(t *TryPreAcceptReply)

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.