client

Documentation

Index

• Variables
• type Client
  • func Dial(address string, options ...Option) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) IngestBatch(ctx context.Context, batch []Event) error
• type Event
• type Option
  • func WithCircuit(timeout time.Duration, maxConcurrent, errorThresholdPercent int) Option
  • func WithCredential(credentials credentials.TransportCredentials) Option
  • func WithNetwork(dialTimeout time.Duration) Option
  • func WithNonBlock() Option

Variables

var (
	// ErrUnableToConnect is error when client is unable connect to rpc server
	ErrUnableToConnect = errors.New("unable to connect Talaria server")
)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client represents a client for Talaria.

func Dial

func Dial(address string, options ...Option) (*Client, error)

Dial creates a new client and connect to Talaria grpc server.

func (*Client) Close

func (c *Client) Close() error

Close connection

func (*Client) IngestBatch

func (c *Client) IngestBatch(ctx context.Context, batch []Event) error

IngestBatch sends a batch of events to Talaria server.

type Event

type Event map[string]interface{}

Event represents a single event.

type Option

type Option func(client *Client)

Option is a functional parameter used to configure the client.

func WithCircuit

func WithCircuit(timeout time.Duration, maxConcurrent, errorThresholdPercent int) Option

WithCircuit specifies the configuration for the circuit breaker.

func WithCredential

func WithCredential(credentials credentials.TransportCredentials) Option

WithCredential specfies the configuration for the gRPC credentials based on TLS with this one being set, connection will be created in secure manner

func WithNetwork

func WithNetwork(dialTimeout time.Duration) Option

WithNetwork specifies the configuration for a connection.

func WithNonBlock

func WithNonBlock() Option