stream

Documentation

Overview

Package stream is a generated protocol buffer package.

It is generated from these files:

github.com/ship-os/ship-micro/examples/stream/server/proto/stream.proto

It has these top-level messages:

Request
Response

Index

• func RegisterStreamerHandler(s server.Server, hdlr StreamerHandler, opts ...server.HandlerOption)
• type StreamerHandler
• type StreamerService
  • func NewStreamerService(serviceName string, c client.Client) StreamerService
• type Streamer_ServerStreamService
• type Streamer_ServerStreamStream
• type Streamer_StreamService
• type Streamer_StreamStream

Functions

func RegisterStreamerHandler

func RegisterStreamerHandler(s server.Server, hdlr StreamerHandler, opts ...server.HandlerOption)

Types

type StreamerHandler

type StreamerHandler interface {
	Stream(context.Context, Streamer_StreamStream) error
	ServerStream(context.Context, *Request, Streamer_ServerStreamStream) error
}

type StreamerService

type StreamerService interface {
	Stream(ctx context.Context, opts ...client.CallOption) (Streamer_StreamService, error)
	ServerStream(ctx context.Context, in *Request, opts ...client.CallOption) (Streamer_ServerStreamService, error)
}

func NewStreamerService

func NewStreamerService(serviceName string, c client.Client) StreamerService

type Streamer_ServerStreamService

type Streamer_ServerStreamService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*Response, error)
}

type Streamer_ServerStreamStream

type Streamer_ServerStreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Response) error
}

type Streamer_StreamService

type Streamer_StreamService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Request) error
	Recv() (*Response, error)
}

type Streamer_StreamStream

type Streamer_StreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Response) error
	Recv() (*Request, error)
}