Versions in this module Expand all Collapse all v0 v0.1.0 Oct 31, 2024 Changes in this version + const StatusAckDisabled + const StatusChannelMissing + const StatusEventFieldBlank + const StatusEventFieldRequired + const StatusIncorrectIndex + const StatusInternalServerError + const StatusInvalidAuthorization + const StatusInvalidChannel + const StatusInvalidDataFormat + const StatusInvalidToken + const StatusNoData + const StatusServerBusy + const StatusSuccess + const StatusTokenDisabled + const StatusTokenRequired + var ErrEventTooLong = errors.New("Event length is too long") + func String(str string) *string + type Client struct + func (hec *Client) SetChannel(channel string) + func (hec *Client) SetHTTPClient(client *http.Client) + func (hec *Client) SetKeepAlive(enable bool) + func (hec *Client) SetMaxContentLength(size int) + func (hec *Client) SetMaxRetry(retries int) + func (hec *Client) WriteBatch(events []*Event) error + func (hec *Client) WriteEvent(event *Event) error + func (hec *Client) WriteRaw(reader io.ReadSeeker, metadata *EventMetadata) error + type Cluster struct + func (c *Cluster) SetChannel(channel string) + func (c *Cluster) SetHTTPClient(httpClient *http.Client) + func (c *Cluster) SetKeepAlive(enable bool) + func (c *Cluster) SetMaxContentLength(size int) + func (c *Cluster) SetMaxRetry(retries int) + func (c *Cluster) WriteBatch(events []*Event) error + func (c *Cluster) WriteEvent(event *Event) error + func (c *Cluster) WriteRaw(reader io.ReadSeeker, metadata *EventMetadata) error + type Event struct + Event interface{} + Host *string + Index *string + Source *string + SourceType *string + Time *string + func NewEvent(data interface{}) *Event + func (e *Event) SetHost(host string) + func (e *Event) SetIndex(index string) + func (e *Event) SetSource(source string) + func (e *Event) SetSourceType(sourcetype string) + func (e *Event) SetTime(time time.Time) + type EventMetadata struct + Host *string + Index *string + Source *string + SourceType *string + Time *time.Time + type HEC interface + SetChannel func(channel string) + SetHTTPClient func(client *http.Client) + SetKeepAlive func(enable bool) + SetMaxContentLength func(size int) + SetMaxRetry func(retries int) + WriteBatch func(events []*Event) error + WriteEvent func(event *Event) error + WriteRaw func(reader io.ReadSeeker, metadata *EventMetadata) error + func NewClient(serverURL string, token string) HEC + func NewCluster(serverURLs []string, token string) HEC + type Response struct + Code int + Text string + func (res *Response) Error() string + func (res *Response) String() string
Go to main page