grpc

Documentation

Overview

Package grpc :

Index

• type ConnectorGrpc
  • func NewConnectorGrpc(grpcConnection string, timeoutMax int64, shoset *sn.Shoset) (connectorGrpc ConnectorGrpc, err error)
  • func (r ConnectorGrpc) CreateIteratorCommand(ctx context.Context, in *pb.Empty) (iteratorMessage *pb.IteratorMessage, err error)
  • func (r ConnectorGrpc) CreateIteratorEvent(ctx context.Context, in *pb.Empty) (iteratorMessage *pb.IteratorMessage, err error)
  • func (r ConnectorGrpc) SendCommandList(ctx context.Context, in *pb.CommandList) (validate *pb.Validate, err error)
  • func (r ConnectorGrpc) SendCommandMessage(ctx context.Context, in *pb.CommandMessage) (commandMessageUUID *pb.CommandMessageUUID, err error)
  • func (r ConnectorGrpc) SendEventMessage(ctx context.Context, in *pb.EventMessage) (empty *pb.Empty, err error)
  • func (r ConnectorGrpc) SendStop(ctx context.Context, in *pb.Stop) (validate *pb.Validate, err error)
  • func (r ConnectorGrpc) StartGrpcServer()
  • func (r ConnectorGrpc) WaitCommandMessage(ctx context.Context, in *pb.CommandMessageWait) (commandMessage *pb.CommandMessage, err error)
  • func (r ConnectorGrpc) WaitEventMessage(ctx context.Context, in *pb.EventMessageWait) (messageEvent *pb.EventMessage, err error)
  • func (r ConnectorGrpc) WaitTopicMessage(ctx context.Context, in *pb.TopicMessageWait) (messageEvent *pb.EventMessage, err error)

Types

type ConnectorGrpc

type ConnectorGrpc struct {
	pb.UnimplementedConnectorServer
	pb.UnimplementedConnectorCommandServer
	pb.UnimplementedConnectorEventServer
	GrpcConnection string
	Shoset         sn.Shoset
	//MapWorkerIterators map[string][]*msg.Iterator
	MapIterators      map[string]*msg.Iterator
	MapCommandChannel map[string]chan msg.Message
	EventChannel      chan msg.Message
	ValidationChannel chan msg.Message
	// contains filtered or unexported fields
}

ConnectorGrpc : ConnectorGrpc struct.

func NewConnectorGrpc

func NewConnectorGrpc(grpcConnection string, timeoutMax int64, shoset *sn.Shoset) (connectorGrpc ConnectorGrpc, err error)

NewConnectorGrpc : ConnectorGrpc constructor.

func (ConnectorGrpc) CreateIteratorCommand

func (r ConnectorGrpc) CreateIteratorCommand(ctx context.Context, in *pb.Empty) (iteratorMessage *pb.IteratorMessage, err error)

CreateIteratorCommand : Connector create command iterator function.

func (ConnectorGrpc) CreateIteratorEvent

func (r ConnectorGrpc) CreateIteratorEvent(ctx context.Context, in *pb.Empty) (iteratorMessage *pb.IteratorMessage, err error)

CreateIteratorEvent : Connector create event iterator function.

func (ConnectorGrpc) SendCommandList

func (r ConnectorGrpc) SendCommandList(ctx context.Context, in *pb.CommandList) (validate *pb.Validate, err error)

SendCommandList : Connector send command list function.

func (ConnectorGrpc) SendCommandMessage

func (r ConnectorGrpc) SendCommandMessage(ctx context.Context, in *pb.CommandMessage) (commandMessageUUID *pb.CommandMessageUUID, err error)

SendCommandMessage : Connector send command function.

func (ConnectorGrpc) SendEventMessage

func (r ConnectorGrpc) SendEventMessage(ctx context.Context, in *pb.EventMessage) (empty *pb.Empty, err error)

SendEventMessage : Connector send event function.

func (ConnectorGrpc) SendStop

func (r ConnectorGrpc) SendStop(ctx context.Context, in *pb.Stop) (validate *pb.Validate, err error)

SendStop : Connector send stop.

func (ConnectorGrpc) StartGrpcServer

func (r ConnectorGrpc) StartGrpcServer()

StartGrpcServer : ConnectorGrpc start.

func (ConnectorGrpc) WaitCommandMessage

func (r ConnectorGrpc) WaitCommandMessage(ctx context.Context, in *pb.CommandMessageWait) (commandMessage *pb.CommandMessage, err error)

WaitCommandMessage : Connector wait command function.

func (ConnectorGrpc) WaitEventMessage

func (r ConnectorGrpc) WaitEventMessage(ctx context.Context, in *pb.EventMessageWait) (messageEvent *pb.EventMessage, err error)

WaitEventMessage : Connector wait event function.

func (ConnectorGrpc) WaitTopicMessage

func (r ConnectorGrpc) WaitTopicMessage(ctx context.Context, in *pb.TopicMessageWait) (messageEvent *pb.EventMessage, err error)

WaitTopicMessage : Connector wait event by topic function.