clientrpc

package

v0.2.1 Latest Latest Go to latest Published: Dec 10, 2019 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RPCWorker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

RPCWorker stream worker

func NewRPCWorker(workers *worker.Workers, id int, label string) *RPCWorker

NewRPCWorker create a new RPCWorker

func (w *RPCWorker) Command(c int)

Command sent to this worker

func (w *RPCWorker) ID() int

ID return label of worker

func (w *RPCWorker) Label() string

Label return label of worker

func (w *RPCWorker) Run(wg *sync.WaitGroup, term *chan int)

Run is main function of this worker

func (w *RPCWorker) SendTextMessage(ctx context.Context, t *clientapi.TextMessage) (*clientapi.TextMessageResponse, error)

SendTextMessage rpc entry point

func (w *RPCWorker) Status(empty *empty.Empty, stream clientapi.ClientService_StatusServer) error

Status rpc entry point

func (w *RPCWorker) Subscriptions() []*worker.Subscription

Subscriptions return a copy of current scubscriptions

func (w *RPCWorker) Terminate()

Terminate the worker