sessionreducer

Documentation

Index

• type Client
  • func New(serverInfo *serverinfo.ServerInfo, inputOptions ...sdkclient.Option) (Client, error)
  • func NewFromClient(c sessionreducepb.SessionReduceClient) (Client, error)

Types

type Client

type Client interface {
	CloseConn(ctx context.Context) error
	IsReady(ctx context.Context, in *emptypb.Empty) (bool, error)
	SessionReduceFn(ctx context.Context, datumStreamCh <-chan *sessionreducepb.SessionReduceRequest) (<-chan *sessionreducepb.SessionReduceResponse, <-chan error)
}

Client contains methods to call a gRPC client.

func New

func New(serverInfo *serverinfo.ServerInfo, inputOptions ...sdkclient.Option) (Client, error)

New creates a new client object.

func NewFromClient

func NewFromClient(c sessionreducepb.SessionReduceClient) (Client, error)