sideinput

Documentation

Index

• func New(inputOptions ...Option) (*client, error)
• type Client
  • func NewFromClient(c sideinputpb.SideInputClient) (Client, error)
• type Option
  • func WithMaxMessageSize(size int) Option
  • func WithSideInputTimeout(t time.Duration) Option
  • func WithSockAddr(addr string) Option

Functions

func New

func New(inputOptions ...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.

type Option

type Option func(*options)

Option is the interface to apply options.

func WithMaxMessageSize

func WithMaxMessageSize(size int) Option

WithMaxMessageSize sets the max message size to the given size.

func WithSideInputTimeout

func WithSideInputTimeout(t time.Duration) Option

WithSideInputTimeout sets the side input timeout to the given timeout.

func WithSockAddr

func WithSockAddr(addr string) Option

WithSockAddr start the client with the given sock addr. This is mainly used for testing purpose.