datanode

Documentation

Index

• func StartDataNodeServer(listen string, kvType KVType, dataDir string)
• type Client
  • func NewClient(rpcAddress string) (datanode *Client, err error)
• type DataNodeClient
• type Header
• type KVType

Functions

func StartDataNodeServer

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

StartDataNodeServer is the gRPC server for the MutDataNode

Types

type Client

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

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

NewClient creates a grpc connection to a slice

type DataNodeClient

type DataNodeClient interface {
	proto.DataNodeClient
}

type Header

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
)