datanode

Documentation

Index

• Constants
• func BlockFileFormat(rootDir string, handle common.BlockHandle) string
• func Run(rootDir string, addr, masterAddr common.NodeAddress, nodeType common.NodeType)
• type Block
• type DataNode
  • func (d *DataNode) CreateBlock(args ipc.CreateBlockArgs, response *ipc.CreateBlockResponse) error
  • func (d *DataNode) ForwardBlocks(args ipc.ForwardDataArgs, response *ipc.ForwardDataResponse) error
  • func (d *DataNode) GarbageCollection() error
  • func (d *DataNode) Heartbeat() error
  • func (d *DataNode) ReadBlock(args ipc.ReadBlockArgs, response *ipc.ReadBlockResponse) error
  • func (d *DataNode) RemoveBlock(handle common.BlockHandle) error
  • func (d *DataNode) WriteBlock(args ipc.WriteBlockArgs, response *ipc.WriteBlockResponse) error
• type Forward

Constants

const (
	BlockPermission = 0644
)

Functions

func BlockFileFormat

func BlockFileFormat(rootDir string, handle common.BlockHandle) string

func Run

func Run(rootDir string, addr, masterAddr common.NodeAddress, nodeType common.NodeType)

Types

type Block

type Block struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DataNode

type DataNode struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*DataNode) CreateBlock

func (d *DataNode) CreateBlock(args ipc.CreateBlockArgs, response *ipc.CreateBlockResponse) error

func (*DataNode) ForwardBlocks

func (d *DataNode) ForwardBlocks(args ipc.ForwardDataArgs, response *ipc.ForwardDataResponse) error

func (*DataNode) GarbageCollection

func (d *DataNode) GarbageCollection() error

func (*DataNode) Heartbeat

func (d *DataNode) Heartbeat() error

func (*DataNode) ReadBlock

func (d *DataNode) ReadBlock(args ipc.ReadBlockArgs, response *ipc.ReadBlockResponse) error

func (*DataNode) RemoveBlock

func (d *DataNode) RemoveBlock(handle common.BlockHandle) error

func (*DataNode) WriteBlock

func (d *DataNode) WriteBlock(args ipc.WriteBlockArgs, response *ipc.WriteBlockResponse) error

type Forward

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