data

package
v1.1.2155 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 2, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v1.0.514 

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.