v1

Documentation

Index

• type Handle
  • func (h Handle) Connected(ctx context.Context, addr *net.TCPAddr, stream chan<- v1.Task) (e error)
  • func (h Handle) Disconnected(addr *net.TCPAddr)
  • func (h Handle) HandoverRequested(addr *net.TCPAddr) (e error)
  • func (h Handle) Reported(req *v1.ReportRequest) (e error)
• type TaskAssigner
  • func (ta TaskAssigner) Assign(ctx context.Context, t interface{}) (e error)
  • func (ta TaskAssigner) Close()

Types

type Handle

type Handle struct {
}

Handle is handler for invokee service

func (Handle) Connected

func (h Handle) Connected(
	ctx context.Context,
	addr *net.TCPAddr,
	stream chan<- v1.Task,
) (e error)

Connected is invoked when invokee client connected.

func (Handle) Disconnected

func (h Handle) Disconnected(addr *net.TCPAddr)

Disconnected is invoked when invokee client disconnected

func (Handle) HandoverRequested

func (h Handle) HandoverRequested(addr *net.TCPAddr) (e error)

HandoverRequested not supported for this agent delegate.

func (Handle) Reported

func (h Handle) Reported(req *v1.ReportRequest) (e error)

Reported is invoked when the invokee client requested to report for the task.

type TaskAssigner

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

TaskAssigner holds stream for assigning a task to the worker.

func (TaskAssigner) Assign

func (ta TaskAssigner) Assign(ctx context.Context, t interface{}) (e error)

Assign sends the specified task to the worker.

func (TaskAssigner) Close

func (ta TaskAssigner) Close()

Close closes the connected channel