datanode

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Feb 1, 2024 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartDataNodeServer added in v0.2.0

func StartDataNodeServer(listen string, kvType KVType, dataDir string)

StartDataNodeServer is the gRPC server for the MutDataNode

Types

type Client added in v0.2.0

type Client struct {
	DataClient  proto.DataNodeClient
	HeartClient healthpb.HealthClient
	RpcAddress  string
	Conn        *grpc.ClientConn
}

Client is a node that stores erasure-coded sharded data

func NewClient added in v0.2.0

func NewClient(rpcAddress string) (datanode *Client, err error)

NewClient creates a grpc connection to a slice

type DataNodeClient added in v0.2.0

type DataNodeClient interface {
	proto.DataNodeClient
}
type Header struct {
	Checksum uint32
	MetaSize int32
	DataSize int32
}

type KVType

type KVType string

KVType is the type of kv

const (
	//KVBadge is the kv type of badger
	KVBadge KVType = "badger"
	//KVMutcask is the kv type of mutcask
	KVMutcask KVType = "mutcask"

	// HeaderSize is size of entry header
	HeaderSize = 12
)

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL