px

package
v0.0.32 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppendEntriesRequest added in v0.0.31 

func AppendEntriesRequest(r *v1.AppendEntriesRequest) *raft.AppendEntriesRequest

func AppendEntriesRequestFrom added in v0.0.31 

func AppendEntriesRequestFrom(r *raft.AppendEntriesRequest) *v1.AppendEntriesRequest

func AppendEntriesResponse added in v0.0.31 

func AppendEntriesResponse(r *v1.AppendEntriesResponse) *raft.AppendEntriesResponse

func AppendEntriesResponseFrom added in v0.0.31 

func AppendEntriesResponseFrom(r *raft.AppendEntriesResponse) *v1.AppendEntriesResponse

func Azure added in v0.0.32 

func Azure(o *configv1.BlockStore_Azure) azure.Config

func Bos added in v0.0.32 

func Bos(o *configv1.BlockStore_BOS) bos.Config

func ColumnIndex 

func ColumnIndex(c storev1.Column) int

func Cos added in v0.0.32 

func Cos(o *configv1.BlockStore_COS) cos.Config

func Decode added in v0.0.32 

func Decode(m proto.Message) func(val []byte) error

func Filesystem added in v0.0.32 

func Filesystem(o *configv1.BlockStore_Filesystem) *filesystem.Config

func GCS added in v0.0.32 

func GCS(o *configv1.BlockStore_GCS) gcs.Config
func Header(r *v1.Header) raft.RPCHeader

func HeaderFrom added in v0.0.31 

func HeaderFrom(r *raft.RPCHeader) *v1.Header

func InstallSnapshotRequest added in v0.0.31 

func InstallSnapshotRequest(r *v1.InstallSnapshotRequest) *raft.InstallSnapshotRequest

func InstallSnapshotRequestFrom added in v0.0.31 

func InstallSnapshotRequestFrom(r *raft.InstallSnapshotRequest) *v1.InstallSnapshotRequest

func InstallSnapshotResponse added in v0.0.31 

func InstallSnapshotResponse(r *v1.InstallSnapshotResponse) *raft.InstallSnapshotResponse

func InstallSnapshotResponseFrom added in v0.0.31 

func InstallSnapshotResponseFrom(r *raft.InstallSnapshotResponse) *v1.InstallSnapshotResponse

func Interface 

func Interface(v *v1.Query_Value) (val any)

func NewQueryValue 

func NewQueryValue(v any) *v1.Query_Value

func OBS added in v0.0.32 

func OBS(o *configv1.BlockStore_OBS) obs.Config

func OSS added in v0.0.32 

func OSS(o *configv1.BlockStore_OSS) oss.Config

func RaftEntry added in v0.0.31 

func RaftEntry(r *v1.RaftEntry) *badger.Entry

func RaftEntryFrom added in v0.0.31 

func RaftEntryFrom(key, value []byte, ttl time.Duration) *v1.RaftEntry

func RaftLog added in v0.0.31 

func RaftLog(r *v1.RaftLog) *raft.Log

func RaftLogFrom added in v0.0.31 

func RaftLogFrom(r *raft.Log) *v1.RaftLog

func RequestVoteRequest added in v0.0.31 

func RequestVoteRequest(r *v1.RequestVoteRequest) *raft.RequestVoteRequest

func RequestVoteRequestFrom added in v0.0.31 

func RequestVoteRequestFrom(r *raft.RequestVoteRequest) *v1.RequestVoteRequest

func RequestVoteResponse added in v0.0.31 

func RequestVoteResponse(r *v1.RequestVoteResponse) *raft.RequestVoteResponse

func RequestVoteResponseFrom added in v0.0.31 

func RequestVoteResponseFrom(r *raft.RequestVoteResponse) *v1.RequestVoteResponse

func S3 added in v0.0.32 

func S3(o *configv1.BlockStore_S3) s3.Config

func TimeoutNowRequest added in v0.0.31 

func TimeoutNowRequest(r *v1.TimeoutNowRequest) *raft.TimeoutNowRequest

func TimeoutNowRequestFrom added in v0.0.31 

func TimeoutNowRequestFrom(r *raft.TimeoutNowRequest) *v1.TimeoutNowRequest

func TimeoutNowResponse added in v0.0.31 

func TimeoutNowResponse(r *v1.TimeoutNowResponse) *raft.TimeoutNowResponse

func TimeoutNowResponseFrom added in v0.0.31 

func TimeoutNowResponseFrom(r *raft.TimeoutNowResponse) *v1.TimeoutNowResponse

Types

This section is empty.

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.