sideinput

Documentation

Index

• func New(serverInfo *info.ServerInfo, inputOptions ...sdkclient.Option) (*client, error)
• type Client
  • func NewFromClient(c sideinputpb.SideInputClient) (Client, error)

Functions

func New

func New(serverInfo *info.ServerInfo, inputOptions ...sdkclient.Option) (*client, error)

New creates a new client object.

Types

type Client

type Client interface {
	CloseConn(ctx context.Context) error
	IsReady(ctx context.Context, in *emptypb.Empty) (bool, error)
	RetrieveSideInput(ctx context.Context, in *emptypb.Empty) (*sideinputpb.SideInputResponse, error)
}

Client contains methods to call a gRPC client for side input.

func NewFromClient

func NewFromClient(c sideinputpb.SideInputClient) (Client, error)

NewFromClient creates a new client object from a grpc client. This is used for testing.