data

Documentation

Index

• func WithConcurrency(n int) concurrency
• func WithEphemeralStorage() ephemeralStorage
• type Client
  • func New(option ...Option) *Client
  • func (c *Client) Dial(ctx context.Context, natsURL string, opts ...nats.Option) error
  • func (c *Client) GetServerVersion(ctx context.Context) (*version.Version, error)
• type Option

Functions

func WithConcurrency

func WithConcurrency(n int) concurrency

WithConcurrency specifies the number of threads to process each service task.

func WithEphemeralStorage

func WithEphemeralStorage() ephemeralStorage

WithEphemeralStorage specifies a client store the result of all operations in memory.

Types

type Client

type Client struct {
	ExpectedServerVersion           *version.Version
	ExpectedCompatibleServerVersion *version.Version
	SendMiddleware                  []middleware2.Send
	ReceiveMiddleware               []middleware2.Receive
	// contains filtered or unexported fields
}

Client implements a SHAR data client capable of retrieving raw data about workflow history

func New

func New(option ...Option) *Client

New creates a new SHAR data client instance

func (*Client) Dial

func (c *Client) Dial(ctx context.Context, natsURL string, opts ...nats.Option) error

Dial instructs the client to connect to a NATS server.

func (*Client) GetServerVersion

func (c *Client) GetServerVersion(ctx context.Context) (*version.Version, error)

GetServerVersion returns the current server version.

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option represents a configuration changer for the client.