foobar

package module
v0.0.0-...-cbdd025 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

README

raft-capnp-transport

WORK IN PROGRESS

Documentation

Overview

Package transport provides a Transport for github.com/hashicorp/raft over Capnproto.

Index

Constants

View Source 
const RaftTransport_LogType_TypeID = 0x8c3e88f463832eea

RaftTransport_LogType_TypeID is the unique identifier for the type RaftTransport_LogType.

View Source 
const RaftTransport_Log_TypeID = 0xc9b7901c714e1cfe

RaftTransport_Log_TypeID is the unique identifier for the type RaftTransport_Log.

View Source 
const RaftTransport_RpcHeader_TypeID = 0x9befdc0c32667b42

RaftTransport_RpcHeader_TypeID is the unique identifier for the type RaftTransport_RpcHeader.

View Source 
const RaftTransport_TypeID = 0xb3384108b060ed0c

RaftTransport_TypeID is the unique identifier for the type RaftTransport.

View Source 
const RaftTransport_appendEntries_Params_TypeID = 0xf60d7d7110329c91

RaftTransport_appendEntries_Params_TypeID is the unique identifier for the type RaftTransport_appendEntries_Params.

View Source 
const RaftTransport_appendEntries_Results_TypeID = 0xd1e595a84b2056db

RaftTransport_appendEntries_Results_TypeID is the unique identifier for the type RaftTransport_appendEntries_Results.

View Source 
const RaftTransport_appendStream_Params_TypeID = 0xcf275fa14d609124

RaftTransport_appendStream_Params_TypeID is the unique identifier for the type RaftTransport_appendStream_Params.

View Source 
const RaftTransport_appendStream_Results_TypeID = 0xbfd6618757a5d3ba

RaftTransport_appendStream_Results_TypeID is the unique identifier for the type RaftTransport_appendStream_Results.

View Source 
const RaftTransport_installSnapshot_Params_TypeID = 0xaa7bdb586393ba80

RaftTransport_installSnapshot_Params_TypeID is the unique identifier for the type RaftTransport_installSnapshot_Params.

View Source 
const RaftTransport_installSnapshot_Results_TypeID = 0xa7c37ffd5aa76201

RaftTransport_installSnapshot_Results_TypeID is the unique identifier for the type RaftTransport_installSnapshot_Results.

View Source 
const RaftTransport_requestVote_Params_TypeID = 0xe9f51c7251030d94

RaftTransport_requestVote_Params_TypeID is the unique identifier for the type RaftTransport_requestVote_Params.

View Source 
const RaftTransport_requestVote_Results_TypeID = 0xd02521e4f2f96083

RaftTransport_requestVote_Results_TypeID is the unique identifier for the type RaftTransport_requestVote_Results.

View Source 
const RaftTransport_timeoutNow_Params_TypeID = 0xc7702dcc74c3ba32

RaftTransport_timeoutNow_Params_TypeID is the unique identifier for the type RaftTransport_timeoutNow_Params.

View Source 
const RaftTransport_timeoutNow_Results_TypeID = 0x93170655133f9d22

RaftTransport_timeoutNow_Results_TypeID is the unique identifier for the type RaftTransport_timeoutNow_Results.

Variables

This section is empty.

Functions

func RaftTransport_Methods 

func RaftTransport_Methods(methods []server.Method, s RaftTransport_Server) []server.Method

RaftTransport_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func RaftTransport_NewServer 

func RaftTransport_NewServer(s RaftTransport_Server) *server.Server

RaftTransport_NewServer creates a new Server from an implementation of RaftTransport_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

Types

type Manager 

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

func New 

func New(localAddress raft.ServerAddress, options ...Option) *Manager

New creates both components of raft-grpc-transport: a gRPC service and a Raft Transport.

func (*Manager) Close 

func (m *Manager) Close() error

func (*Manager) Transport 

func (m *Manager) Transport() raft.Transport

Transport returns a raft.Transport that communicates over gRPC.

type RaftTransport 

type RaftTransport capnp.Client

func RaftTransport_ServerToClient 

func RaftTransport_ServerToClient(s RaftTransport_Server) RaftTransport

RaftTransport_ServerToClient creates a new Client from an implementation of RaftTransport_Server. The caller is responsible for calling Release on the returned Client.

func (RaftTransport) AddRef 

func (c RaftTransport) AddRef() RaftTransport

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (RaftTransport) AppendEntries 

func (c RaftTransport) AppendEntries(ctx context.Context, params func(RaftTransport_appendEntries_Params) error) (RaftTransport_appendEntries_Results_Future, capnp.ReleaseFunc)

func (RaftTransport) AppendStream 

func (c RaftTransport) AppendStream(ctx context.Context, params func(RaftTransport_appendStream_Params) error) (RaftTransport_appendStream_Results_Future, capnp.ReleaseFunc)

func (RaftTransport) DecodeFromPtr 

func (RaftTransport) DecodeFromPtr(p capnp.Ptr) RaftTransport

func (RaftTransport) EncodeAsPtr 

func (c RaftTransport) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport) GetFlowLimiter 

func (c RaftTransport) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (RaftTransport) InstallSnapshot 

func (c RaftTransport) InstallSnapshot(ctx context.Context, params func(RaftTransport_installSnapshot_Params) error) (RaftTransport_installSnapshot_Results_Future, capnp.ReleaseFunc)

func (RaftTransport) IsSame 

func (c RaftTransport) IsSame(other RaftTransport) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (RaftTransport) IsValid 

func (c RaftTransport) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (RaftTransport) Release 

func (c RaftTransport) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (RaftTransport) RequestVote 

func (c RaftTransport) RequestVote(ctx context.Context, params func(RaftTransport_requestVote_Params) error) (RaftTransport_requestVote_Results_Future, capnp.ReleaseFunc)

func (RaftTransport) Resolve 

func (c RaftTransport) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (RaftTransport) SetFlowLimiter 

func (c RaftTransport) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (RaftTransport) String 

func (c RaftTransport) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (RaftTransport) TimeoutNow 

func (c RaftTransport) TimeoutNow(ctx context.Context, params func(RaftTransport_timeoutNow_Params) error) (RaftTransport_timeoutNow_Results_Future, capnp.ReleaseFunc)

func (RaftTransport) WaitStreaming 

func (c RaftTransport) WaitStreaming() error

type RaftTransportServer 

type RaftTransportServer struct{}

These are calls from the Raft engine that we need to send out over gRPC.

func (RaftTransportServer) RequestVote 

func (RaftTransportServer) RequestVote(ctx context.Context, call RaftTransport_requestVote) error

type RaftTransport_List 

type RaftTransport_List = capnp.CapList[RaftTransport]

RaftTransport_List is a list of RaftTransport.

func NewRaftTransport_List 

func NewRaftTransport_List(s *capnp.Segment, sz int32) (RaftTransport_List, error)

NewRaftTransport creates a new list of RaftTransport.

type RaftTransport_Log 

type RaftTransport_Log capnp.Struct

func NewRaftTransport_Log 

func NewRaftTransport_Log(s *capnp.Segment) (RaftTransport_Log, error)

func NewRootRaftTransport_Log 

func NewRootRaftTransport_Log(s *capnp.Segment) (RaftTransport_Log, error)

func ReadRootRaftTransport_Log 

func ReadRootRaftTransport_Log(msg *capnp.Message) (RaftTransport_Log, error)

func (RaftTransport_Log) AppendedAt 

func (s RaftTransport_Log) AppendedAt() uint64

func (RaftTransport_Log) Data 

func (s RaftTransport_Log) Data() ([]byte, error)

func (RaftTransport_Log) DecodeFromPtr 

func (RaftTransport_Log) DecodeFromPtr(p capnp.Ptr) RaftTransport_Log

func (RaftTransport_Log) EncodeAsPtr 

func (s RaftTransport_Log) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_Log) Extensions 

func (s RaftTransport_Log) Extensions() ([]byte, error)

func (RaftTransport_Log) HasData 

func (s RaftTransport_Log) HasData() bool

func (RaftTransport_Log) HasExtensions 

func (s RaftTransport_Log) HasExtensions() bool

func (RaftTransport_Log) Index 

func (s RaftTransport_Log) Index() uint64

func (RaftTransport_Log) IsValid 

func (s RaftTransport_Log) IsValid() bool

func (RaftTransport_Log) Message 

func (s RaftTransport_Log) Message() *capnp.Message

func (RaftTransport_Log) Segment 

func (s RaftTransport_Log) Segment() *capnp.Segment

func (RaftTransport_Log) SetAppendedAt 

func (s RaftTransport_Log) SetAppendedAt(v uint64)

func (RaftTransport_Log) SetData 

func (s RaftTransport_Log) SetData(v []byte) error

func (RaftTransport_Log) SetExtensions 

func (s RaftTransport_Log) SetExtensions(v []byte) error

func (RaftTransport_Log) SetIndex 

func (s RaftTransport_Log) SetIndex(v uint64)

func (RaftTransport_Log) SetTerm 

func (s RaftTransport_Log) SetTerm(v uint64)

func (RaftTransport_Log) SetType 

func (s RaftTransport_Log) SetType(v RaftTransport_LogType)

func (RaftTransport_Log) String 

func (s RaftTransport_Log) String() string

func (RaftTransport_Log) Term 

func (s RaftTransport_Log) Term() uint64

func (RaftTransport_Log) ToPtr 

func (s RaftTransport_Log) ToPtr() capnp.Ptr

func (RaftTransport_Log) Type 

func (s RaftTransport_Log) Type() RaftTransport_LogType

type RaftTransport_LogType 

type RaftTransport_LogType uint16
const (
	RaftTransport_LogType_command              RaftTransport_LogType = 0
	RaftTransport_LogType_noop                 RaftTransport_LogType = 1
	RaftTransport_LogType_addPeerDeprecated    RaftTransport_LogType = 2
	RaftTransport_LogType_removePeerDeprecated RaftTransport_LogType = 3
	RaftTransport_LogType_barrier              RaftTransport_LogType = 4
	RaftTransport_LogType_configuration        RaftTransport_LogType = 5
)

Values of RaftTransport_LogType.

func RaftTransport_LogTypeFromString 

func RaftTransport_LogTypeFromString(c string) RaftTransport_LogType

RaftTransport_LogTypeFromString returns the enum value with a name, or the zero value if there's no such value.

func (RaftTransport_LogType) String 

func (c RaftTransport_LogType) String() string

String returns the enum's constant name.

type RaftTransport_LogType_List 

type RaftTransport_LogType_List = capnp.EnumList[RaftTransport_LogType]

func NewRaftTransport_LogType_List 

func NewRaftTransport_LogType_List(s *capnp.Segment, sz int32) (RaftTransport_LogType_List, error)

type RaftTransport_Log_Future 

type RaftTransport_Log_Future struct{ *capnp.Future }

RaftTransport_Log_Future is a wrapper for a RaftTransport_Log promised by a client call.

func (RaftTransport_Log_Future) Struct 

func (f RaftTransport_Log_Future) Struct() (RaftTransport_Log, error)

type RaftTransport_Log_List 

type RaftTransport_Log_List = capnp.StructList[RaftTransport_Log]

RaftTransport_Log_List is a list of RaftTransport_Log.

func NewRaftTransport_Log_List 

func NewRaftTransport_Log_List(s *capnp.Segment, sz int32) (RaftTransport_Log_List, error)

NewRaftTransport_Log creates a new list of RaftTransport_Log.

type RaftTransport_RpcHeader 

type RaftTransport_RpcHeader capnp.Struct

func NewRaftTransport_RpcHeader 

func NewRaftTransport_RpcHeader(s *capnp.Segment) (RaftTransport_RpcHeader, error)

func NewRootRaftTransport_RpcHeader 

func NewRootRaftTransport_RpcHeader(s *capnp.Segment) (RaftTransport_RpcHeader, error)

func ReadRootRaftTransport_RpcHeader 

func ReadRootRaftTransport_RpcHeader(msg *capnp.Message) (RaftTransport_RpcHeader, error)

func (RaftTransport_RpcHeader) Addr 

func (s RaftTransport_RpcHeader) Addr() ([]byte, error)

func (RaftTransport_RpcHeader) DecodeFromPtr 

func (RaftTransport_RpcHeader) DecodeFromPtr(p capnp.Ptr) RaftTransport_RpcHeader

func (RaftTransport_RpcHeader) EncodeAsPtr 

func (s RaftTransport_RpcHeader) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_RpcHeader) HasAddr 

func (s RaftTransport_RpcHeader) HasAddr() bool

func (RaftTransport_RpcHeader) HasId 

func (s RaftTransport_RpcHeader) HasId() bool

func (RaftTransport_RpcHeader) Id 

func (s RaftTransport_RpcHeader) Id() ([]byte, error)

func (RaftTransport_RpcHeader) IsValid 

func (s RaftTransport_RpcHeader) IsValid() bool

func (RaftTransport_RpcHeader) Message 

func (s RaftTransport_RpcHeader) Message() *capnp.Message

func (RaftTransport_RpcHeader) Segment 

func (s RaftTransport_RpcHeader) Segment() *capnp.Segment

func (RaftTransport_RpcHeader) SetAddr 

func (s RaftTransport_RpcHeader) SetAddr(v []byte) error

func (RaftTransport_RpcHeader) SetId 

func (s RaftTransport_RpcHeader) SetId(v []byte) error

func (RaftTransport_RpcHeader) SetVersion 

func (s RaftTransport_RpcHeader) SetVersion(v int64)

func (RaftTransport_RpcHeader) String 

func (s RaftTransport_RpcHeader) String() string

func (RaftTransport_RpcHeader) ToPtr 

func (s RaftTransport_RpcHeader) ToPtr() capnp.Ptr

func (RaftTransport_RpcHeader) Version 

func (s RaftTransport_RpcHeader) Version() int64

type RaftTransport_RpcHeader_Future 

type RaftTransport_RpcHeader_Future struct{ *capnp.Future }

RaftTransport_RpcHeader_Future is a wrapper for a RaftTransport_RpcHeader promised by a client call.

func (RaftTransport_RpcHeader_Future) Struct 

func (f RaftTransport_RpcHeader_Future) Struct() (RaftTransport_RpcHeader, error)

type RaftTransport_RpcHeader_List 

type RaftTransport_RpcHeader_List = capnp.StructList[RaftTransport_RpcHeader]

RaftTransport_RpcHeader_List is a list of RaftTransport_RpcHeader.

func NewRaftTransport_RpcHeader_List 

func NewRaftTransport_RpcHeader_List(s *capnp.Segment, sz int32) (RaftTransport_RpcHeader_List, error)

NewRaftTransport_RpcHeader creates a new list of RaftTransport_RpcHeader.

type RaftTransport_Server 

type RaftTransport_Server interface {
	AppendStream(context.Context, RaftTransport_appendStream) error

	AppendEntries(context.Context, RaftTransport_appendEntries) error

	RequestVote(context.Context, RaftTransport_requestVote) error

	TimeoutNow(context.Context, RaftTransport_timeoutNow) error

	InstallSnapshot(context.Context, RaftTransport_installSnapshot) error
}

A RaftTransport_Server is a RaftTransport with a local implementation.

type RaftTransport_appendEntries 

type RaftTransport_appendEntries struct {
	*server.Call
}

RaftTransport_appendEntries holds the state for a server call to RaftTransport.appendEntries. See server.Call for documentation.

func (RaftTransport_appendEntries) AllocResults 

func (c RaftTransport_appendEntries) AllocResults() (RaftTransport_appendEntries_Results, error)

AllocResults allocates the results struct.

func (RaftTransport_appendEntries) Args 

func (c RaftTransport_appendEntries) Args() RaftTransport_appendEntries_Params

Args returns the call's arguments.

type RaftTransport_appendEntries_Params 

type RaftTransport_appendEntries_Params capnp.Struct

func NewRaftTransport_appendEntries_Params 

func NewRaftTransport_appendEntries_Params(s *capnp.Segment) (RaftTransport_appendEntries_Params, error)

func NewRootRaftTransport_appendEntries_Params 

func NewRootRaftTransport_appendEntries_Params(s *capnp.Segment) (RaftTransport_appendEntries_Params, error)

func ReadRootRaftTransport_appendEntries_Params 

func ReadRootRaftTransport_appendEntries_Params(msg *capnp.Message) (RaftTransport_appendEntries_Params, error)

func (RaftTransport_appendEntries_Params) DecodeFromPtr 

func (RaftTransport_appendEntries_Params) DecodeFromPtr(p capnp.Ptr) RaftTransport_appendEntries_Params

func (RaftTransport_appendEntries_Params) EncodeAsPtr 

func (s RaftTransport_appendEntries_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_appendEntries_Params) Entries 

func (s RaftTransport_appendEntries_Params) Entries() (RaftTransport_Log_List, error)

func (RaftTransport_appendEntries_Params) HasEntries 

func (s RaftTransport_appendEntries_Params) HasEntries() bool

func (RaftTransport_appendEntries_Params) HasHeader 

func (s RaftTransport_appendEntries_Params) HasHeader() bool

func (RaftTransport_appendEntries_Params) HasLeader 

func (s RaftTransport_appendEntries_Params) HasLeader() bool

func (RaftTransport_appendEntries_Params) Header 

func (s RaftTransport_appendEntries_Params) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_appendEntries_Params) IsValid 

func (s RaftTransport_appendEntries_Params) IsValid() bool

func (RaftTransport_appendEntries_Params) Leader 

func (s RaftTransport_appendEntries_Params) Leader() ([]byte, error)

func (RaftTransport_appendEntries_Params) Message 

func (s RaftTransport_appendEntries_Params) Message() *capnp.Message

func (RaftTransport_appendEntries_Params) NewEntries 

func (s RaftTransport_appendEntries_Params) NewEntries(n int32) (RaftTransport_Log_List, error)

NewEntries sets the entries field to a newly allocated RaftTransport_Log_List, preferring placement in s's segment.

func (RaftTransport_appendEntries_Params) NewHeader 

func (s RaftTransport_appendEntries_Params) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_appendEntries_Params) PrevLogEntry 

func (s RaftTransport_appendEntries_Params) PrevLogEntry() uint64

func (RaftTransport_appendEntries_Params) PrevLogTerm 

func (s RaftTransport_appendEntries_Params) PrevLogTerm() uint64

func (RaftTransport_appendEntries_Params) Segment 

func (s RaftTransport_appendEntries_Params) Segment() *capnp.Segment

func (RaftTransport_appendEntries_Params) SetEntries 

func (s RaftTransport_appendEntries_Params) SetEntries(v RaftTransport_Log_List) error

func (RaftTransport_appendEntries_Params) SetHeader 

func (s RaftTransport_appendEntries_Params) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_appendEntries_Params) SetLeader 

func (s RaftTransport_appendEntries_Params) SetLeader(v []byte) error

func (RaftTransport_appendEntries_Params) SetPrevLogEntry 

func (s RaftTransport_appendEntries_Params) SetPrevLogEntry(v uint64)

func (RaftTransport_appendEntries_Params) SetPrevLogTerm 

func (s RaftTransport_appendEntries_Params) SetPrevLogTerm(v uint64)

func (RaftTransport_appendEntries_Params) SetTerm 

func (s RaftTransport_appendEntries_Params) SetTerm(v uint64)

func (RaftTransport_appendEntries_Params) String 

func (s RaftTransport_appendEntries_Params) String() string

func (RaftTransport_appendEntries_Params) Term 

func (s RaftTransport_appendEntries_Params) Term() uint64

func (RaftTransport_appendEntries_Params) ToPtr 

func (s RaftTransport_appendEntries_Params) ToPtr() capnp.Ptr

type RaftTransport_appendEntries_Params_Future 

type RaftTransport_appendEntries_Params_Future struct{ *capnp.Future }

RaftTransport_appendEntries_Params_Future is a wrapper for a RaftTransport_appendEntries_Params promised by a client call.

func (RaftTransport_appendEntries_Params_Future) Header 

func (p RaftTransport_appendEntries_Params_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_appendEntries_Params_Future) Struct 

func (f RaftTransport_appendEntries_Params_Future) Struct() (RaftTransport_appendEntries_Params, error)

type RaftTransport_appendEntries_Params_List 

type RaftTransport_appendEntries_Params_List = capnp.StructList[RaftTransport_appendEntries_Params]

RaftTransport_appendEntries_Params_List is a list of RaftTransport_appendEntries_Params.

func NewRaftTransport_appendEntries_Params_List 

func NewRaftTransport_appendEntries_Params_List(s *capnp.Segment, sz int32) (RaftTransport_appendEntries_Params_List, error)

NewRaftTransport_appendEntries_Params creates a new list of RaftTransport_appendEntries_Params.

type RaftTransport_appendEntries_Results 

type RaftTransport_appendEntries_Results capnp.Struct

func NewRaftTransport_appendEntries_Results 

func NewRaftTransport_appendEntries_Results(s *capnp.Segment) (RaftTransport_appendEntries_Results, error)

func NewRootRaftTransport_appendEntries_Results 

func NewRootRaftTransport_appendEntries_Results(s *capnp.Segment) (RaftTransport_appendEntries_Results, error)

func ReadRootRaftTransport_appendEntries_Results 

func ReadRootRaftTransport_appendEntries_Results(msg *capnp.Message) (RaftTransport_appendEntries_Results, error)

func (RaftTransport_appendEntries_Results) DecodeFromPtr 

func (RaftTransport_appendEntries_Results) DecodeFromPtr(p capnp.Ptr) RaftTransport_appendEntries_Results

func (RaftTransport_appendEntries_Results) EncodeAsPtr 

func (s RaftTransport_appendEntries_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_appendEntries_Results) HasHeader 

func (s RaftTransport_appendEntries_Results) HasHeader() bool

func (RaftTransport_appendEntries_Results) Header 

func (s RaftTransport_appendEntries_Results) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_appendEntries_Results) IsValid 

func (s RaftTransport_appendEntries_Results) IsValid() bool

func (RaftTransport_appendEntries_Results) LastLog 

func (s RaftTransport_appendEntries_Results) LastLog() uint64

func (RaftTransport_appendEntries_Results) Message 

func (s RaftTransport_appendEntries_Results) Message() *capnp.Message

func (RaftTransport_appendEntries_Results) NewHeader 

func (s RaftTransport_appendEntries_Results) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_appendEntries_Results) NoRetryBackoff 

func (s RaftTransport_appendEntries_Results) NoRetryBackoff() bool

func (RaftTransport_appendEntries_Results) Segment 

func (s RaftTransport_appendEntries_Results) Segment() *capnp.Segment

func (RaftTransport_appendEntries_Results) SetHeader 

func (s RaftTransport_appendEntries_Results) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_appendEntries_Results) SetLastLog 

func (s RaftTransport_appendEntries_Results) SetLastLog(v uint64)

func (RaftTransport_appendEntries_Results) SetNoRetryBackoff 

func (s RaftTransport_appendEntries_Results) SetNoRetryBackoff(v bool)

func (RaftTransport_appendEntries_Results) SetSuccess 

func (s RaftTransport_appendEntries_Results) SetSuccess(v bool)

func (RaftTransport_appendEntries_Results) SetTerm 

func (s RaftTransport_appendEntries_Results) SetTerm(v uint64)

func (RaftTransport_appendEntries_Results) String 

func (s RaftTransport_appendEntries_Results) String() string

func (RaftTransport_appendEntries_Results) Success 

func (s RaftTransport_appendEntries_Results) Success() bool

func (RaftTransport_appendEntries_Results) Term 

func (s RaftTransport_appendEntries_Results) Term() uint64

func (RaftTransport_appendEntries_Results) ToPtr 

func (s RaftTransport_appendEntries_Results) ToPtr() capnp.Ptr

type RaftTransport_appendEntries_Results_Future 

type RaftTransport_appendEntries_Results_Future struct{ *capnp.Future }

RaftTransport_appendEntries_Results_Future is a wrapper for a RaftTransport_appendEntries_Results promised by a client call.

func (RaftTransport_appendEntries_Results_Future) Header 

func (p RaftTransport_appendEntries_Results_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_appendEntries_Results_Future) Struct 

func (f RaftTransport_appendEntries_Results_Future) Struct() (RaftTransport_appendEntries_Results, error)

type RaftTransport_appendEntries_Results_List 

type RaftTransport_appendEntries_Results_List = capnp.StructList[RaftTransport_appendEntries_Results]

RaftTransport_appendEntries_Results_List is a list of RaftTransport_appendEntries_Results.

func NewRaftTransport_appendEntries_Results_List 

func NewRaftTransport_appendEntries_Results_List(s *capnp.Segment, sz int32) (RaftTransport_appendEntries_Results_List, error)

NewRaftTransport_appendEntries_Results creates a new list of RaftTransport_appendEntries_Results.

type RaftTransport_appendStream 

type RaftTransport_appendStream struct {
	*server.Call
}

RaftTransport_appendStream holds the state for a server call to RaftTransport.appendStream. See server.Call for documentation.

func (RaftTransport_appendStream) AllocResults 

func (c RaftTransport_appendStream) AllocResults() (RaftTransport_appendStream_Results, error)

AllocResults allocates the results struct.

func (RaftTransport_appendStream) Args 

func (c RaftTransport_appendStream) Args() RaftTransport_appendStream_Params

Args returns the call's arguments.

type RaftTransport_appendStream_Params 

type RaftTransport_appendStream_Params capnp.Struct

func NewRaftTransport_appendStream_Params 

func NewRaftTransport_appendStream_Params(s *capnp.Segment) (RaftTransport_appendStream_Params, error)

func NewRootRaftTransport_appendStream_Params 

func NewRootRaftTransport_appendStream_Params(s *capnp.Segment) (RaftTransport_appendStream_Params, error)

func ReadRootRaftTransport_appendStream_Params 

func ReadRootRaftTransport_appendStream_Params(msg *capnp.Message) (RaftTransport_appendStream_Params, error)

func (RaftTransport_appendStream_Params) DecodeFromPtr 

func (RaftTransport_appendStream_Params) DecodeFromPtr(p capnp.Ptr) RaftTransport_appendStream_Params

func (RaftTransport_appendStream_Params) EncodeAsPtr 

func (s RaftTransport_appendStream_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_appendStream_Params) IsValid 

func (s RaftTransport_appendStream_Params) IsValid() bool

func (RaftTransport_appendStream_Params) Message 

func (s RaftTransport_appendStream_Params) Message() *capnp.Message

func (RaftTransport_appendStream_Params) Segment 

func (s RaftTransport_appendStream_Params) Segment() *capnp.Segment

func (RaftTransport_appendStream_Params) String 

func (s RaftTransport_appendStream_Params) String() string

func (RaftTransport_appendStream_Params) ToPtr 

func (s RaftTransport_appendStream_Params) ToPtr() capnp.Ptr

type RaftTransport_appendStream_Params_Future 

type RaftTransport_appendStream_Params_Future struct{ *capnp.Future }

RaftTransport_appendStream_Params_Future is a wrapper for a RaftTransport_appendStream_Params promised by a client call.

func (RaftTransport_appendStream_Params_Future) Struct 

func (f RaftTransport_appendStream_Params_Future) Struct() (RaftTransport_appendStream_Params, error)

type RaftTransport_appendStream_Params_List 

type RaftTransport_appendStream_Params_List = capnp.StructList[RaftTransport_appendStream_Params]

RaftTransport_appendStream_Params_List is a list of RaftTransport_appendStream_Params.

func NewRaftTransport_appendStream_Params_List 

func NewRaftTransport_appendStream_Params_List(s *capnp.Segment, sz int32) (RaftTransport_appendStream_Params_List, error)

NewRaftTransport_appendStream_Params creates a new list of RaftTransport_appendStream_Params.

type RaftTransport_appendStream_Results 

type RaftTransport_appendStream_Results capnp.Struct

func NewRaftTransport_appendStream_Results 

func NewRaftTransport_appendStream_Results(s *capnp.Segment) (RaftTransport_appendStream_Results, error)

func NewRootRaftTransport_appendStream_Results 

func NewRootRaftTransport_appendStream_Results(s *capnp.Segment) (RaftTransport_appendStream_Results, error)

func ReadRootRaftTransport_appendStream_Results 

func ReadRootRaftTransport_appendStream_Results(msg *capnp.Message) (RaftTransport_appendStream_Results, error)

func (RaftTransport_appendStream_Results) DecodeFromPtr 

func (RaftTransport_appendStream_Results) DecodeFromPtr(p capnp.Ptr) RaftTransport_appendStream_Results

func (RaftTransport_appendStream_Results) EncodeAsPtr 

func (s RaftTransport_appendStream_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_appendStream_Results) IsValid 

func (s RaftTransport_appendStream_Results) IsValid() bool

func (RaftTransport_appendStream_Results) Message 

func (s RaftTransport_appendStream_Results) Message() *capnp.Message

func (RaftTransport_appendStream_Results) Segment 

func (s RaftTransport_appendStream_Results) Segment() *capnp.Segment

func (RaftTransport_appendStream_Results) String 

func (s RaftTransport_appendStream_Results) String() string

func (RaftTransport_appendStream_Results) ToPtr 

func (s RaftTransport_appendStream_Results) ToPtr() capnp.Ptr

type RaftTransport_appendStream_Results_Future 

type RaftTransport_appendStream_Results_Future struct{ *capnp.Future }

RaftTransport_appendStream_Results_Future is a wrapper for a RaftTransport_appendStream_Results promised by a client call.

func (RaftTransport_appendStream_Results_Future) Struct 

func (f RaftTransport_appendStream_Results_Future) Struct() (RaftTransport_appendStream_Results, error)

type RaftTransport_appendStream_Results_List 

type RaftTransport_appendStream_Results_List = capnp.StructList[RaftTransport_appendStream_Results]

RaftTransport_appendStream_Results_List is a list of RaftTransport_appendStream_Results.

func NewRaftTransport_appendStream_Results_List 

func NewRaftTransport_appendStream_Results_List(s *capnp.Segment, sz int32) (RaftTransport_appendStream_Results_List, error)

NewRaftTransport_appendStream_Results creates a new list of RaftTransport_appendStream_Results.

type RaftTransport_installSnapshot 

type RaftTransport_installSnapshot struct {
	*server.Call
}

RaftTransport_installSnapshot holds the state for a server call to RaftTransport.installSnapshot. See server.Call for documentation.

func (RaftTransport_installSnapshot) AllocResults 

func (c RaftTransport_installSnapshot) AllocResults() (RaftTransport_installSnapshot_Results, error)

AllocResults allocates the results struct.

func (RaftTransport_installSnapshot) Args 

func (c RaftTransport_installSnapshot) Args() RaftTransport_installSnapshot_Params

Args returns the call's arguments.

type RaftTransport_installSnapshot_Params 

type RaftTransport_installSnapshot_Params capnp.Struct

func NewRaftTransport_installSnapshot_Params 

func NewRaftTransport_installSnapshot_Params(s *capnp.Segment) (RaftTransport_installSnapshot_Params, error)

func NewRootRaftTransport_installSnapshot_Params 

func NewRootRaftTransport_installSnapshot_Params(s *capnp.Segment) (RaftTransport_installSnapshot_Params, error)

func ReadRootRaftTransport_installSnapshot_Params 

func ReadRootRaftTransport_installSnapshot_Params(msg *capnp.Message) (RaftTransport_installSnapshot_Params, error)

func (RaftTransport_installSnapshot_Params) Configuration 

func (s RaftTransport_installSnapshot_Params) Configuration() ([]byte, error)

func (RaftTransport_installSnapshot_Params) ConfigurationIndex 

func (s RaftTransport_installSnapshot_Params) ConfigurationIndex() uint64

func (RaftTransport_installSnapshot_Params) DecodeFromPtr 

func (RaftTransport_installSnapshot_Params) DecodeFromPtr(p capnp.Ptr) RaftTransport_installSnapshot_Params

func (RaftTransport_installSnapshot_Params) EncodeAsPtr 

func (s RaftTransport_installSnapshot_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_installSnapshot_Params) HasConfiguration 

func (s RaftTransport_installSnapshot_Params) HasConfiguration() bool

func (RaftTransport_installSnapshot_Params) HasHeader 

func (s RaftTransport_installSnapshot_Params) HasHeader() bool

func (RaftTransport_installSnapshot_Params) HasLeader 

func (s RaftTransport_installSnapshot_Params) HasLeader() bool

func (RaftTransport_installSnapshot_Params) HasPeers 

func (s RaftTransport_installSnapshot_Params) HasPeers() bool

func (RaftTransport_installSnapshot_Params) Header 

func (s RaftTransport_installSnapshot_Params) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_installSnapshot_Params) IsValid 

func (s RaftTransport_installSnapshot_Params) IsValid() bool

func (RaftTransport_installSnapshot_Params) LastLogIndex 

func (s RaftTransport_installSnapshot_Params) LastLogIndex() uint64

func (RaftTransport_installSnapshot_Params) LastLogTerm 

func (s RaftTransport_installSnapshot_Params) LastLogTerm() uint64

func (RaftTransport_installSnapshot_Params) Leader 

func (s RaftTransport_installSnapshot_Params) Leader() ([]byte, error)

func (RaftTransport_installSnapshot_Params) Message 

func (s RaftTransport_installSnapshot_Params) Message() *capnp.Message

func (RaftTransport_installSnapshot_Params) NewHeader 

func (s RaftTransport_installSnapshot_Params) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_installSnapshot_Params) Peers 

func (s RaftTransport_installSnapshot_Params) Peers() ([]byte, error)

func (RaftTransport_installSnapshot_Params) Segment 

func (s RaftTransport_installSnapshot_Params) Segment() *capnp.Segment

func (RaftTransport_installSnapshot_Params) SetConfiguration 

func (s RaftTransport_installSnapshot_Params) SetConfiguration(v []byte) error

func (RaftTransport_installSnapshot_Params) SetConfigurationIndex 

func (s RaftTransport_installSnapshot_Params) SetConfigurationIndex(v uint64)

func (RaftTransport_installSnapshot_Params) SetHeader 

func (s RaftTransport_installSnapshot_Params) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_installSnapshot_Params) SetLastLogIndex 

func (s RaftTransport_installSnapshot_Params) SetLastLogIndex(v uint64)

func (RaftTransport_installSnapshot_Params) SetLastLogTerm 

func (s RaftTransport_installSnapshot_Params) SetLastLogTerm(v uint64)

func (RaftTransport_installSnapshot_Params) SetLeader 

func (s RaftTransport_installSnapshot_Params) SetLeader(v []byte) error

func (RaftTransport_installSnapshot_Params) SetPeers 

func (s RaftTransport_installSnapshot_Params) SetPeers(v []byte) error

func (RaftTransport_installSnapshot_Params) SetSize 

func (s RaftTransport_installSnapshot_Params) SetSize(v int64)

func (RaftTransport_installSnapshot_Params) SetSnapshotVersion 

func (s RaftTransport_installSnapshot_Params) SetSnapshotVersion(v int64)

func (RaftTransport_installSnapshot_Params) SetTerm 

func (s RaftTransport_installSnapshot_Params) SetTerm(v uint64)

func (RaftTransport_installSnapshot_Params) Size 

func (s RaftTransport_installSnapshot_Params) Size() int64

func (RaftTransport_installSnapshot_Params) SnapshotVersion 

func (s RaftTransport_installSnapshot_Params) SnapshotVersion() int64

func (RaftTransport_installSnapshot_Params) String 

func (s RaftTransport_installSnapshot_Params) String() string

func (RaftTransport_installSnapshot_Params) Term 

func (s RaftTransport_installSnapshot_Params) Term() uint64

func (RaftTransport_installSnapshot_Params) ToPtr 

func (s RaftTransport_installSnapshot_Params) ToPtr() capnp.Ptr

type RaftTransport_installSnapshot_Params_Future 

type RaftTransport_installSnapshot_Params_Future struct{ *capnp.Future }

RaftTransport_installSnapshot_Params_Future is a wrapper for a RaftTransport_installSnapshot_Params promised by a client call.

func (RaftTransport_installSnapshot_Params_Future) Header 

func (p RaftTransport_installSnapshot_Params_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_installSnapshot_Params_Future) Struct 

func (f RaftTransport_installSnapshot_Params_Future) Struct() (RaftTransport_installSnapshot_Params, error)

type RaftTransport_installSnapshot_Params_List 

type RaftTransport_installSnapshot_Params_List = capnp.StructList[RaftTransport_installSnapshot_Params]

RaftTransport_installSnapshot_Params_List is a list of RaftTransport_installSnapshot_Params.

func NewRaftTransport_installSnapshot_Params_List 

func NewRaftTransport_installSnapshot_Params_List(s *capnp.Segment, sz int32) (RaftTransport_installSnapshot_Params_List, error)

NewRaftTransport_installSnapshot_Params creates a new list of RaftTransport_installSnapshot_Params.

type RaftTransport_installSnapshot_Results 

type RaftTransport_installSnapshot_Results capnp.Struct

func NewRaftTransport_installSnapshot_Results 

func NewRaftTransport_installSnapshot_Results(s *capnp.Segment) (RaftTransport_installSnapshot_Results, error)

func NewRootRaftTransport_installSnapshot_Results 

func NewRootRaftTransport_installSnapshot_Results(s *capnp.Segment) (RaftTransport_installSnapshot_Results, error)

func ReadRootRaftTransport_installSnapshot_Results 

func ReadRootRaftTransport_installSnapshot_Results(msg *capnp.Message) (RaftTransport_installSnapshot_Results, error)

func (RaftTransport_installSnapshot_Results) DecodeFromPtr 

func (RaftTransport_installSnapshot_Results) DecodeFromPtr(p capnp.Ptr) RaftTransport_installSnapshot_Results

func (RaftTransport_installSnapshot_Results) EncodeAsPtr 

func (s RaftTransport_installSnapshot_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_installSnapshot_Results) HasHeader 

func (s RaftTransport_installSnapshot_Results) HasHeader() bool

func (RaftTransport_installSnapshot_Results) HasSnapshot 

func (s RaftTransport_installSnapshot_Results) HasSnapshot() bool

func (RaftTransport_installSnapshot_Results) Header 

func (s RaftTransport_installSnapshot_Results) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_installSnapshot_Results) IsValid 

func (s RaftTransport_installSnapshot_Results) IsValid() bool

func (RaftTransport_installSnapshot_Results) Message 

func (s RaftTransport_installSnapshot_Results) Message() *capnp.Message

func (RaftTransport_installSnapshot_Results) NewHeader 

func (s RaftTransport_installSnapshot_Results) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_installSnapshot_Results) Segment 

func (s RaftTransport_installSnapshot_Results) Segment() *capnp.Segment

func (RaftTransport_installSnapshot_Results) SetHeader 

func (s RaftTransport_installSnapshot_Results) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_installSnapshot_Results) SetSnapshot 

func (s RaftTransport_installSnapshot_Results) SetSnapshot(v bs.ByteStream) error

func (RaftTransport_installSnapshot_Results) SetSuccess 

func (s RaftTransport_installSnapshot_Results) SetSuccess(v bool)

func (RaftTransport_installSnapshot_Results) SetTerm 

func (s RaftTransport_installSnapshot_Results) SetTerm(v uint64)

func (RaftTransport_installSnapshot_Results) Snapshot 

func (s RaftTransport_installSnapshot_Results) Snapshot() bs.ByteStream

func (RaftTransport_installSnapshot_Results) String 

func (s RaftTransport_installSnapshot_Results) String() string

func (RaftTransport_installSnapshot_Results) Success 

func (s RaftTransport_installSnapshot_Results) Success() bool

func (RaftTransport_installSnapshot_Results) Term 

func (s RaftTransport_installSnapshot_Results) Term() uint64

func (RaftTransport_installSnapshot_Results) ToPtr 

func (s RaftTransport_installSnapshot_Results) ToPtr() capnp.Ptr

type RaftTransport_installSnapshot_Results_Future 

type RaftTransport_installSnapshot_Results_Future struct{ *capnp.Future }

RaftTransport_installSnapshot_Results_Future is a wrapper for a RaftTransport_installSnapshot_Results promised by a client call.

func (RaftTransport_installSnapshot_Results_Future) Header 

func (p RaftTransport_installSnapshot_Results_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_installSnapshot_Results_Future) Snapshot 

func (p RaftTransport_installSnapshot_Results_Future) Snapshot() bs.ByteStream

func (RaftTransport_installSnapshot_Results_Future) Struct 

func (f RaftTransport_installSnapshot_Results_Future) Struct() (RaftTransport_installSnapshot_Results, error)

type RaftTransport_installSnapshot_Results_List 

type RaftTransport_installSnapshot_Results_List = capnp.StructList[RaftTransport_installSnapshot_Results]

RaftTransport_installSnapshot_Results_List is a list of RaftTransport_installSnapshot_Results.

func NewRaftTransport_installSnapshot_Results_List 

func NewRaftTransport_installSnapshot_Results_List(s *capnp.Segment, sz int32) (RaftTransport_installSnapshot_Results_List, error)

NewRaftTransport_installSnapshot_Results creates a new list of RaftTransport_installSnapshot_Results.

type RaftTransport_requestVote 

type RaftTransport_requestVote struct {
	*server.Call
}

RaftTransport_requestVote holds the state for a server call to RaftTransport.requestVote. See server.Call for documentation.

func (RaftTransport_requestVote) AllocResults 

func (c RaftTransport_requestVote) AllocResults() (RaftTransport_requestVote_Results, error)

AllocResults allocates the results struct.

func (RaftTransport_requestVote) Args 

func (c RaftTransport_requestVote) Args() RaftTransport_requestVote_Params

Args returns the call's arguments.

type RaftTransport_requestVote_Params 

type RaftTransport_requestVote_Params capnp.Struct

func NewRaftTransport_requestVote_Params 

func NewRaftTransport_requestVote_Params(s *capnp.Segment) (RaftTransport_requestVote_Params, error)

func NewRootRaftTransport_requestVote_Params 

func NewRootRaftTransport_requestVote_Params(s *capnp.Segment) (RaftTransport_requestVote_Params, error)

func ReadRootRaftTransport_requestVote_Params 

func ReadRootRaftTransport_requestVote_Params(msg *capnp.Message) (RaftTransport_requestVote_Params, error)

func (RaftTransport_requestVote_Params) Candidate 

func (s RaftTransport_requestVote_Params) Candidate() ([]byte, error)

func (RaftTransport_requestVote_Params) DecodeFromPtr 

func (RaftTransport_requestVote_Params) DecodeFromPtr(p capnp.Ptr) RaftTransport_requestVote_Params

func (RaftTransport_requestVote_Params) EncodeAsPtr 

func (s RaftTransport_requestVote_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_requestVote_Params) HasCandidate 

func (s RaftTransport_requestVote_Params) HasCandidate() bool

func (RaftTransport_requestVote_Params) HasHeader 

func (s RaftTransport_requestVote_Params) HasHeader() bool

func (RaftTransport_requestVote_Params) Header 

func (s RaftTransport_requestVote_Params) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_requestVote_Params) IsValid 

func (s RaftTransport_requestVote_Params) IsValid() bool

func (RaftTransport_requestVote_Params) LastLogIndex 

func (s RaftTransport_requestVote_Params) LastLogIndex() uint64

func (RaftTransport_requestVote_Params) LastLogTerm 

func (s RaftTransport_requestVote_Params) LastLogTerm() uint64

func (RaftTransport_requestVote_Params) LeadershipTransfer 

func (s RaftTransport_requestVote_Params) LeadershipTransfer() bool

func (RaftTransport_requestVote_Params) Message 

func (s RaftTransport_requestVote_Params) Message() *capnp.Message

func (RaftTransport_requestVote_Params) NewHeader 

func (s RaftTransport_requestVote_Params) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_requestVote_Params) Segment 

func (s RaftTransport_requestVote_Params) Segment() *capnp.Segment

func (RaftTransport_requestVote_Params) SetCandidate 

func (s RaftTransport_requestVote_Params) SetCandidate(v []byte) error

func (RaftTransport_requestVote_Params) SetHeader 

func (s RaftTransport_requestVote_Params) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_requestVote_Params) SetLastLogIndex 

func (s RaftTransport_requestVote_Params) SetLastLogIndex(v uint64)

func (RaftTransport_requestVote_Params) SetLastLogTerm 

func (s RaftTransport_requestVote_Params) SetLastLogTerm(v uint64)

func (RaftTransport_requestVote_Params) SetLeadershipTransfer 

func (s RaftTransport_requestVote_Params) SetLeadershipTransfer(v bool)

func (RaftTransport_requestVote_Params) SetTerm 

func (s RaftTransport_requestVote_Params) SetTerm(v uint64)

func (RaftTransport_requestVote_Params) String 

func (s RaftTransport_requestVote_Params) String() string

func (RaftTransport_requestVote_Params) Term 

func (s RaftTransport_requestVote_Params) Term() uint64

func (RaftTransport_requestVote_Params) ToPtr 

func (s RaftTransport_requestVote_Params) ToPtr() capnp.Ptr

type RaftTransport_requestVote_Params_Future 

type RaftTransport_requestVote_Params_Future struct{ *capnp.Future }

RaftTransport_requestVote_Params_Future is a wrapper for a RaftTransport_requestVote_Params promised by a client call.

func (RaftTransport_requestVote_Params_Future) Header 

func (p RaftTransport_requestVote_Params_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_requestVote_Params_Future) Struct 

func (f RaftTransport_requestVote_Params_Future) Struct() (RaftTransport_requestVote_Params, error)

type RaftTransport_requestVote_Params_List 

type RaftTransport_requestVote_Params_List = capnp.StructList[RaftTransport_requestVote_Params]

RaftTransport_requestVote_Params_List is a list of RaftTransport_requestVote_Params.

func NewRaftTransport_requestVote_Params_List 

func NewRaftTransport_requestVote_Params_List(s *capnp.Segment, sz int32) (RaftTransport_requestVote_Params_List, error)

NewRaftTransport_requestVote_Params creates a new list of RaftTransport_requestVote_Params.

type RaftTransport_requestVote_Results 

type RaftTransport_requestVote_Results capnp.Struct

func NewRaftTransport_requestVote_Results 

func NewRaftTransport_requestVote_Results(s *capnp.Segment) (RaftTransport_requestVote_Results, error)

func NewRootRaftTransport_requestVote_Results 

func NewRootRaftTransport_requestVote_Results(s *capnp.Segment) (RaftTransport_requestVote_Results, error)

func ReadRootRaftTransport_requestVote_Results 

func ReadRootRaftTransport_requestVote_Results(msg *capnp.Message) (RaftTransport_requestVote_Results, error)

func (RaftTransport_requestVote_Results) DecodeFromPtr 

func (RaftTransport_requestVote_Results) DecodeFromPtr(p capnp.Ptr) RaftTransport_requestVote_Results

func (RaftTransport_requestVote_Results) EncodeAsPtr 

func (s RaftTransport_requestVote_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_requestVote_Results) Granted 

func (s RaftTransport_requestVote_Results) Granted() bool

func (RaftTransport_requestVote_Results) HasHeader 

func (s RaftTransport_requestVote_Results) HasHeader() bool

func (RaftTransport_requestVote_Results) HasPeers 

func (s RaftTransport_requestVote_Results) HasPeers() bool

func (RaftTransport_requestVote_Results) Header 

func (s RaftTransport_requestVote_Results) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_requestVote_Results) IsValid 

func (s RaftTransport_requestVote_Results) IsValid() bool

func (RaftTransport_requestVote_Results) Message 

func (s RaftTransport_requestVote_Results) Message() *capnp.Message

func (RaftTransport_requestVote_Results) NewHeader 

func (s RaftTransport_requestVote_Results) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_requestVote_Results) Peers 

func (s RaftTransport_requestVote_Results) Peers() ([]byte, error)

func (RaftTransport_requestVote_Results) Segment 

func (s RaftTransport_requestVote_Results) Segment() *capnp.Segment

func (RaftTransport_requestVote_Results) SetGranted 

func (s RaftTransport_requestVote_Results) SetGranted(v bool)

func (RaftTransport_requestVote_Results) SetHeader 

func (s RaftTransport_requestVote_Results) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_requestVote_Results) SetPeers 

func (s RaftTransport_requestVote_Results) SetPeers(v []byte) error

func (RaftTransport_requestVote_Results) SetTerm 

func (s RaftTransport_requestVote_Results) SetTerm(v uint64)

func (RaftTransport_requestVote_Results) String 

func (s RaftTransport_requestVote_Results) String() string

func (RaftTransport_requestVote_Results) Term 

func (s RaftTransport_requestVote_Results) Term() uint64

func (RaftTransport_requestVote_Results) ToPtr 

func (s RaftTransport_requestVote_Results) ToPtr() capnp.Ptr

type RaftTransport_requestVote_Results_Future 

type RaftTransport_requestVote_Results_Future struct{ *capnp.Future }

RaftTransport_requestVote_Results_Future is a wrapper for a RaftTransport_requestVote_Results promised by a client call.

func (RaftTransport_requestVote_Results_Future) Header 

func (p RaftTransport_requestVote_Results_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_requestVote_Results_Future) Struct 

func (f RaftTransport_requestVote_Results_Future) Struct() (RaftTransport_requestVote_Results, error)

type RaftTransport_requestVote_Results_List 

type RaftTransport_requestVote_Results_List = capnp.StructList[RaftTransport_requestVote_Results]

RaftTransport_requestVote_Results_List is a list of RaftTransport_requestVote_Results.

func NewRaftTransport_requestVote_Results_List 

func NewRaftTransport_requestVote_Results_List(s *capnp.Segment, sz int32) (RaftTransport_requestVote_Results_List, error)

NewRaftTransport_requestVote_Results creates a new list of RaftTransport_requestVote_Results.

type RaftTransport_timeoutNow 

type RaftTransport_timeoutNow struct {
	*server.Call
}

RaftTransport_timeoutNow holds the state for a server call to RaftTransport.timeoutNow. See server.Call for documentation.

func (RaftTransport_timeoutNow) AllocResults 

func (c RaftTransport_timeoutNow) AllocResults() (RaftTransport_timeoutNow_Results, error)

AllocResults allocates the results struct.

func (RaftTransport_timeoutNow) Args 

func (c RaftTransport_timeoutNow) Args() RaftTransport_timeoutNow_Params

Args returns the call's arguments.

type RaftTransport_timeoutNow_Params 

type RaftTransport_timeoutNow_Params capnp.Struct

func NewRaftTransport_timeoutNow_Params 

func NewRaftTransport_timeoutNow_Params(s *capnp.Segment) (RaftTransport_timeoutNow_Params, error)

func NewRootRaftTransport_timeoutNow_Params 

func NewRootRaftTransport_timeoutNow_Params(s *capnp.Segment) (RaftTransport_timeoutNow_Params, error)

func ReadRootRaftTransport_timeoutNow_Params 

func ReadRootRaftTransport_timeoutNow_Params(msg *capnp.Message) (RaftTransport_timeoutNow_Params, error)

func (RaftTransport_timeoutNow_Params) DecodeFromPtr 

func (RaftTransport_timeoutNow_Params) DecodeFromPtr(p capnp.Ptr) RaftTransport_timeoutNow_Params

func (RaftTransport_timeoutNow_Params) EncodeAsPtr 

func (s RaftTransport_timeoutNow_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_timeoutNow_Params) HasHeader 

func (s RaftTransport_timeoutNow_Params) HasHeader() bool

func (RaftTransport_timeoutNow_Params) Header 

func (s RaftTransport_timeoutNow_Params) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_timeoutNow_Params) IsValid 

func (s RaftTransport_timeoutNow_Params) IsValid() bool

func (RaftTransport_timeoutNow_Params) Message 

func (s RaftTransport_timeoutNow_Params) Message() *capnp.Message

func (RaftTransport_timeoutNow_Params) NewHeader 

func (s RaftTransport_timeoutNow_Params) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_timeoutNow_Params) Segment 

func (s RaftTransport_timeoutNow_Params) Segment() *capnp.Segment

func (RaftTransport_timeoutNow_Params) SetHeader 

func (s RaftTransport_timeoutNow_Params) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_timeoutNow_Params) String 

func (s RaftTransport_timeoutNow_Params) String() string

func (RaftTransport_timeoutNow_Params) ToPtr 

func (s RaftTransport_timeoutNow_Params) ToPtr() capnp.Ptr

type RaftTransport_timeoutNow_Params_Future 

type RaftTransport_timeoutNow_Params_Future struct{ *capnp.Future }

RaftTransport_timeoutNow_Params_Future is a wrapper for a RaftTransport_timeoutNow_Params promised by a client call.

func (RaftTransport_timeoutNow_Params_Future) Header 

func (p RaftTransport_timeoutNow_Params_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_timeoutNow_Params_Future) Struct 

func (f RaftTransport_timeoutNow_Params_Future) Struct() (RaftTransport_timeoutNow_Params, error)

type RaftTransport_timeoutNow_Params_List 

type RaftTransport_timeoutNow_Params_List = capnp.StructList[RaftTransport_timeoutNow_Params]

RaftTransport_timeoutNow_Params_List is a list of RaftTransport_timeoutNow_Params.

func NewRaftTransport_timeoutNow_Params_List 

func NewRaftTransport_timeoutNow_Params_List(s *capnp.Segment, sz int32) (RaftTransport_timeoutNow_Params_List, error)

NewRaftTransport_timeoutNow_Params creates a new list of RaftTransport_timeoutNow_Params.

type RaftTransport_timeoutNow_Results 

type RaftTransport_timeoutNow_Results capnp.Struct

func NewRaftTransport_timeoutNow_Results 

func NewRaftTransport_timeoutNow_Results(s *capnp.Segment) (RaftTransport_timeoutNow_Results, error)

func NewRootRaftTransport_timeoutNow_Results 

func NewRootRaftTransport_timeoutNow_Results(s *capnp.Segment) (RaftTransport_timeoutNow_Results, error)

func ReadRootRaftTransport_timeoutNow_Results 

func ReadRootRaftTransport_timeoutNow_Results(msg *capnp.Message) (RaftTransport_timeoutNow_Results, error)

func (RaftTransport_timeoutNow_Results) DecodeFromPtr 

func (RaftTransport_timeoutNow_Results) DecodeFromPtr(p capnp.Ptr) RaftTransport_timeoutNow_Results

func (RaftTransport_timeoutNow_Results) EncodeAsPtr 

func (s RaftTransport_timeoutNow_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (RaftTransport_timeoutNow_Results) HasHeader 

func (s RaftTransport_timeoutNow_Results) HasHeader() bool

func (RaftTransport_timeoutNow_Results) Header 

func (s RaftTransport_timeoutNow_Results) Header() (RaftTransport_RpcHeader, error)

func (RaftTransport_timeoutNow_Results) IsValid 

func (s RaftTransport_timeoutNow_Results) IsValid() bool

func (RaftTransport_timeoutNow_Results) Message 

func (s RaftTransport_timeoutNow_Results) Message() *capnp.Message

func (RaftTransport_timeoutNow_Results) NewHeader 

func (s RaftTransport_timeoutNow_Results) NewHeader() (RaftTransport_RpcHeader, error)

NewHeader sets the header field to a newly allocated RaftTransport_RpcHeader struct, preferring placement in s's segment.

func (RaftTransport_timeoutNow_Results) Segment 

func (s RaftTransport_timeoutNow_Results) Segment() *capnp.Segment

func (RaftTransport_timeoutNow_Results) SetHeader 

func (s RaftTransport_timeoutNow_Results) SetHeader(v RaftTransport_RpcHeader) error

func (RaftTransport_timeoutNow_Results) String 

func (s RaftTransport_timeoutNow_Results) String() string

func (RaftTransport_timeoutNow_Results) ToPtr 

func (s RaftTransport_timeoutNow_Results) ToPtr() capnp.Ptr

type RaftTransport_timeoutNow_Results_Future 

type RaftTransport_timeoutNow_Results_Future struct{ *capnp.Future }

RaftTransport_timeoutNow_Results_Future is a wrapper for a RaftTransport_timeoutNow_Results promised by a client call.

func (RaftTransport_timeoutNow_Results_Future) Header 

func (p RaftTransport_timeoutNow_Results_Future) Header() RaftTransport_RpcHeader_Future

func (RaftTransport_timeoutNow_Results_Future) Struct 

func (f RaftTransport_timeoutNow_Results_Future) Struct() (RaftTransport_timeoutNow_Results, error)

type RaftTransport_timeoutNow_Results_List 

type RaftTransport_timeoutNow_Results_List = capnp.StructList[RaftTransport_timeoutNow_Results]

RaftTransport_timeoutNow_Results_List is a list of RaftTransport_timeoutNow_Results.

func NewRaftTransport_timeoutNow_Results_List 

func NewRaftTransport_timeoutNow_Results_List(s *capnp.Segment, sz int32) (RaftTransport_timeoutNow_Results_List, error)

NewRaftTransport_timeoutNow_Results creates a new list of RaftTransport_timeoutNow_Results.

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.