client

package

v0.0.0-...-7638244 Latest Latest Go to latest Published: Apr 22, 2020 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/grab/talaria

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
latency

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL