operations

Documentation

Index

• type Service
  • func (o *Service) Receive(ctx context.Context, stream *pb.ReceiveRequest) (*pb.Operation, error)
  • func (o *Service) Watch(request *pb.ReceiveRequest, stream pb.OperationService_WatchServer) error

Types

type Service

type Service struct {
	pb.UnimplementedOperationServiceServer
}

func (*Service) Receive

func (o *Service) Receive(ctx context.Context, stream *pb.ReceiveRequest) (*pb.Operation, error)

func (*Service) Watch

func (o *Service) Watch(request *pb.ReceiveRequest, stream pb.OperationService_WatchServer) error