remote

type Client ¶

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

Client connect to a remote grpc endpoint

func NewClient(opts ClientOptions) *Client

func (c *Client) Process(ctx context.Context, args selina.ProcessArgs) error

type ClientOptions ¶

type ClientOptions struct {
	Address string
}

ClientOptions customize client

type Error ¶

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor() ([]byte, []int)

func (x *Error) GetMessage() string

func (*Error) ProtoMessage()

func (x *Error) ProtoReflect() protoreflect.Message

func (x *Error) Reset()

func (x *Error) String() string

type Message ¶

type Message struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor() ([]byte, []int)

func (x *Message) GetData() []byte

func (*Message) ProtoMessage()

func (x *Message) ProtoReflect() protoreflect.Message

func (x *Message) Reset()

func (x *Message) String() string

type Server ¶

type Server struct {
	UnimplementedWorkerServer
	// contains filtered or unexported fields
}

Server receive data from a remote endpoint

func NewServer(opts ServerOptions) *Server

func (s *Server) Process(ctx context.Context, args selina.ProcessArgs) (errp error)

func (s *Server) Push(msg []byte) error

func (s *Server) Send(ctx context.Context, msg *Message) (*Error, error)

type ServerOptions ¶

type ServerOptions struct {
	Network    string
	Address    string
	BufferSize int
}

ServerOptions customize Server Worker

type UnimplementedWorkerServer ¶

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServer) Send(context.Context, *Message) (*Error, error)

type UnsafeWorkerServer ¶ added in v0.12.0

type UnsafeWorkerServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServer will result in compilation errors.

type WorkerClient ¶

type WorkerClient interface {
	Send(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Error, error)
}

WorkerClient is the client API for Worker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerServer ¶

type WorkerServer interface {
	Send(context.Context, *Message) (*Error, error)
	// contains filtered or unexported methods
}

WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility