objectdetectionserver

Documentation

Index

• func ConfigureDummyWorkload() gocv.Mat
• func Run(ip, listenPort string)
• type ApplicationInfo
• type ClientState
• type TaskServer
  • func (ts *TaskServer) End_process(ctx context.Context, emptyMessage *clientToTask.EmptyMessage) (*clientToTask.EmptyMessage, error)
  • func (ts *TaskServer) Join_Request(ctx context.Context, decision *clientToTask.Decision) (*clientToTask.JoinResult, error)
  • func (ts *TaskServer) PerformDummyWorkload(delay time.Duration, joinOrLeave bool)
  • func (ts *TaskServer) PerformDummyWorkloadWithDelay(delay time.Duration)
  • func (ts *TaskServer) PerformFrame(mat gocv.Mat)
  • func (ts *TaskServer) Probe_Request(ctx context.Context, testPerf *clientToTask.TestPerf) (*clientToTask.ProbeResult, error)
  • func (ts *TaskServer) RTT_Request(ctx context.Context, testPerf *clientToTask.TestPerf) (*clientToTask.PerfData, error)
  • func (ts *TaskServer) SendRecvImage(stream clientToTask.RpcClientToTask_SendRecvImageServer) error
  • func (ts *TaskServer) Unexpected_client_join(ctx context.Context, emptyMessage *clientToTask.EmptyMessage) (*clientToTask.EmptyMessage, error)

Functions

func ConfigureDummyWorkload

func ConfigureDummyWorkload() gocv.Mat

func Run

func Run(ip, listenPort string)

Types

type ApplicationInfo

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

type ClientState

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

type TaskServer

type TaskServer struct {
	clientToTask.UnimplementedRpcClientToTaskServer
	// Server config
	IP         string
	ListenPort string
	// contains filtered or unexported fields
}

func (*TaskServer) End_process

func (ts *TaskServer) End_process(ctx context.Context, emptyMessage *clientToTask.EmptyMessage) (*clientToTask.EmptyMessage, error)

func (*TaskServer) Join_Request

func (ts *TaskServer) Join_Request(ctx context.Context, decision *clientToTask.Decision) (*clientToTask.JoinResult, error)

func (*TaskServer) PerformDummyWorkload

func (ts *TaskServer) PerformDummyWorkload(delay time.Duration, joinOrLeave bool)

func (*TaskServer) PerformDummyWorkloadWithDelay

func (ts *TaskServer) PerformDummyWorkloadWithDelay(delay time.Duration)

func (*TaskServer) PerformFrame

func (ts *TaskServer) PerformFrame(mat gocv.Mat)

func (*TaskServer) Probe_Request

func (ts *TaskServer) Probe_Request(ctx context.Context, testPerf *clientToTask.TestPerf) (*clientToTask.ProbeResult, error)

func (*TaskServer) RTT_Request

func (ts *TaskServer) RTT_Request(ctx context.Context, testPerf *clientToTask.TestPerf) (*clientToTask.PerfData, error)

func (*TaskServer) SendRecvImage

func (ts *TaskServer) SendRecvImage(stream clientToTask.RpcClientToTask_SendRecvImageServer) error

func (*TaskServer) Unexpected_client_join

func (ts *TaskServer) Unexpected_client_join(ctx context.Context, emptyMessage *clientToTask.EmptyMessage) (*clientToTask.EmptyMessage, error)