service

Documentation

Index

• Variables
• func NewServiceTree(abs tree.Path, ...) *serviceTree
• type CallerInfo
• type Manager
  • func NewManager(host node.HostID) *Manager
  • func (man *Manager) CallService(entry string, cap uuid.UUID, data []byte, caller process.Process) ([]byte, error)
  • func (man *Manager) Init(procMan *process.Manager, callRemote callRemote, callBroadcast callBroadcast, ...) error
  • func (man *Manager) LockAction(path string, host uuid.UUID, action bool) bool
  • func (man *Manager) Sync(info *tree.Transfer) (*tree.Transfer, error)

Variables

var ErrExist = errors.New("service/cap exist")

var ErrNotExist = errors.New("service/cap not exist")

var ErrNotService = errors.New("not a service")

var ErrOccupied = errors.New("occupied")

var ErrUnknownProcess = errors.New("unknown process")

var ErrWrongCaller = errors.New("wrong caller")

Functions

func NewServiceTree

func NewServiceTree(abs tree.Path, callFn func(host node.HostID, process uint32, provider uint32, data []byte, ctx context.Context) ([]byte, error), local bool) *serviceTree

Types

type CallerInfo

type CallerInfo struct {
	Host    node.HostID
	Process uint32
}

type Manager

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

func NewManager

func NewManager(host node.HostID) *Manager

func (*Manager) CallService

func (man *Manager) CallService(entry string, cap uuid.UUID, data []byte, caller process.Process) ([]byte, error)

func (*Manager) Init

func (man *Manager) Init(procMan *process.Manager, callRemote callRemote, callBroadcast callBroadcast, remoteCaller remoteCaller, lockFn lockFn, unlockFn lockFn) error

func (*Manager) LockAction

func (man *Manager) LockAction(path string, host uuid.UUID, action bool) bool

func (*Manager) Sync

func (man *Manager) Sync(info *tree.Transfer) (*tree.Transfer, error)