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
  • func (c *Client) IngestBatchWithTable(ctx context.Context, batch []Event, tables []string) error
  • func (c *Client) IngestCSV(ctx context.Context, data []byte) error
  • func (c *Client) IngestORC(ctx context.Context, data []byte) error
  • func (c *Client) IngestParquet(ctx context.Context, data []byte) error
  • func (c *Client) IngestURL(ctx context.Context, url string) error
• type Event
• type Option
  • func WithCircuit(timeout time.Duration, maxConcurrent, errorThresholdPercent int) Option
  • func WithCredential(credentials credentials.TransportCredentials) Option
  • func WithLoadBalancer(name string) Option
  • func WithMaxMsgSize(maxSendMsgSize, maxRecvMsgSize int) 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.

func (*Client) IngestBatchWithTable

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

IngestBatch sends a batch of events to Talaria server.

func (*Client) IngestCSV

func (c *Client) IngestCSV(ctx context.Context, data []byte) error

IngestCSV sends a set of comma-separated file to Talaria to ingest.

func (*Client) IngestORC

func (c *Client) IngestORC(ctx context.Context, data []byte) error

IngestORC sends an ORC-encoded file to Talaria to ingest.

func (*Client) IngestParquet

func (c *Client) IngestParquet(ctx context.Context, data []byte) error

IngestParquet sends an Parquet-encoded file to Talaria to ingest.

func (*Client) IngestURL

func (c *Client) IngestURL(ctx context.Context, url string) error

IngestURL sends a request to Talaria to ingest a file from a specific URL.

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 WithLoadBalancer

func WithLoadBalancer(name string) Option

WithLoadBalancer specifies the load balancer to use

func WithMaxMsgSize

func WithMaxMsgSize(maxSendMsgSize, maxRecvMsgSize int) Option

func WithNetwork

func WithNetwork(dialTimeout time.Duration) Option

WithNetwork specifies the configuration for a connection.

func WithNonBlock

func WithNonBlock() Option

WithNonBlock creates a non-blocking gRPC dial()