Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNotConnected indicates failure due to client having no valid connection ErrNotConnected = errors.New("not connected") // ErrJSONEncodeFailed indicates encoding failures ErrJSONEncodeFailed = errors.New("json encode failed") )
Functions ¶
Types ¶
type Client ¶
type Client struct {
Connection
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient( s ClientSettings, ) (*Client, error)
func (*Client) FlushBuffer ¶
func (*Client) PublishEvents ¶
PublishEvents posts all events to the http endpoint. On error a slice with all events not published will be returned.
func (*Client) ResetTimer ¶
func (client *Client) ResetTimer()
type ClientSettings ¶
type ClientSettings struct {
URL string
Proxy *url.URL
TLS *transport.TLSConfig
Username, Password string
Parameters map[string]string
Headers map[string]string
Index outil.Selector
Pipeline *outil.Selector
Timeout time.Duration
CompressionLevel int
BufferMinInterval time.Duration
BufferMaxInterval time.Duration
BufferCount int
}
type Connection ¶
type Connection struct {
URL string
Username string
Password string
Headers map[string]string
// contains filtered or unexported fields
}
func (*Connection) Close ¶
func (conn *Connection) Close() error
func (*Connection) IsConnected ¶
func (conn *Connection) IsConnected() bool
Click to show internal directories.
Click to hide internal directories.