ipc

package
v0.0.0-...-9dc9b3d Latest Latest
Warning

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

Go to latest
Published: Dec 15, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Multi

func Multi(addrs []common.NodeAddress, procedure string, args interface{}) []error

func Single

func Single(addr common.NodeAddress, procedure string, args interface{}, response interface{}) error

Types

type CreateBlockArgs

type CreateBlockArgs struct {
	//handle common.BlockHandle
	Handles []common.BlockHandle
}

type CreateBlockResponse

type CreateBlockResponse struct {
	ResponseCode common.Code
}

type CreateFileArgs

type CreateFileArgs struct {
	Length uint64
}

type CreateFileResponse

type CreateFileResponse struct {
	Key     common.HotKey
	ErrCode common.Code
}

type DeleteFileArgs

type DeleteFileArgs struct {
	Key common.HotKey
}

type DeleteFileResponse

type DeleteFileResponse struct {
	ErrCode common.Code
}

type ForwardDataArgs

type ForwardDataArgs struct {
	Handle common.BlockHandle
	//Data []byte
	Target []common.NodeAddress
}

type ForwardDataResponse

type ForwardDataResponse struct {
	ErrCode common.Code
}

type GetBlockInfoArgs

type GetBlockInfoArgs struct {
	Handle common.BlockHandle
}

type GetBlockInfoResponse

type GetBlockInfoResponse struct {
	// locations
	Locations []common.NodeAddress
	Primary   common.NodeAddress
}

type GetMetadataArgs

type GetMetadataArgs struct {
	FileKey common.HotKey
}

type GetMetadataResponse

type GetMetadataResponse struct {
	// blocks
	BlockHandles []common.BlockHandle
	// length
	Length int64
}

type HeartBeatArgs

type HeartBeatArgs struct {
	Address common.NodeAddress
	DNType  common.NodeType
}

type HeartBeatResponse

type HeartBeatResponse struct {
	Garbage []common.BlockHandle
}

type ListKeysArgs

type ListKeysArgs struct {
	Limit int // how many keys
}

type ListKeysResponse

type ListKeysResponse struct {
	Keys []common.HotKey
}

type NodeStatusArgs

type NodeStatusArgs struct{}

for debug

type NodeStatusResponse

type NodeStatusResponse struct {
	Nodes map[common.NodeAddress]*common.Node
}

type ReadBlockArgs

type ReadBlockArgs struct {
	Handle common.BlockHandle
	Offset common.Offset
	Length int
}

type ReadBlockResponse

type ReadBlockResponse struct {
	Data    []byte
	Length  int
	ErrCode common.Code
}

type WriteBlockArgs

type WriteBlockArgs struct {
	Handle      common.BlockHandle
	Data        []byte
	Offset      common.Offset
	Secondaries []common.NodeAddress
}

type WriteBlockResponse

type WriteBlockResponse struct {
	ErrCode common.Code
}

Jump to

Keyboard shortcuts

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