state

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, conn *grpc.ClientConn, tableName string) (Client, error)
  • func NewClientWithOptions(ctx context.Context, conn *grpc.ClientConn, tableName string, _ ClientOptions) (Client, error)
  • func NewConnectedClient(ctx context.Context, backendOpts *plugin.BackendOptions) (Client, error)
  • func NewConnectedClientWithOptions(ctx context.Context, backendOpts *plugin.BackendOptions, ...) (Client, error)
• type ClientOptions
• type ConnectionOptions
• type NoOpClient
  • func (*NoOpClient) Close() error
  • func (*NoOpClient) Flush(_ context.Context) error
  • func (*NoOpClient) GetKey(_ context.Context, _ string) (string, error)
  • func (*NoOpClient) SetKey(_ context.Context, _ string, _ string) error

Types

type Client

type Client interface {
	SetKey(ctx context.Context, key string, value string) error
	GetKey(ctx context.Context, key string) (string, error)
	Flush(ctx context.Context) error
	Close() error
}

func NewClient

func NewClient(ctx context.Context, conn *grpc.ClientConn, tableName string) (Client, error)

func NewClientWithOptions

func NewClientWithOptions(ctx context.Context, conn *grpc.ClientConn, tableName string, _ ClientOptions) (Client, error)

func NewConnectedClient

func NewConnectedClient(ctx context.Context, backendOpts *plugin.BackendOptions) (Client, error)

NewConnectedClient returns a state client and initialises the gRPC connection to the state backend with a 100MiB max message size. The state client is guaranteed to be non-nil (it defaults to the NoOpClient). You must call Close() on the returned Client object.

func NewConnectedClientWithOptions

func NewConnectedClientWithOptions(ctx context.Context, backendOpts *plugin.BackendOptions, connOpts ConnectionOptions, clOpts ClientOptions) (Client, error)

NewConnectedClientWithOptions returns a state client and initialises the gRPC connection to the state backend. The state client is guaranteed to be non-nil (it defaults to the NoOpClient). You must call Close() on the returned Client object.

type ClientOptions

type ClientOptions struct{}

type ConnectionOptions

type ConnectionOptions struct {
	MaxMsgSizeInBytes int
}

type NoOpClient

type NoOpClient struct{}

func (*NoOpClient) Close

func (*NoOpClient) Close() error

func (*NoOpClient) Flush

func (*NoOpClient) Flush(_ context.Context) error

func (*NoOpClient) GetKey

func (*NoOpClient) GetKey(_ context.Context, _ string) (string, error)

func (*NoOpClient) SetKey

func (*NoOpClient) SetKey(_ context.Context, _ string, _ string) error