Documentation
¶
Index ¶
- func BatchSize(size int) func(*BatchClientConfig)
- func EnqueueTimeout(timeout time.Duration) func(*BatchClientConfig)
- func FlushInterval(interval time.Duration) func(*BatchClientConfig)
- type APIClient
- type APIClientImpl
- type BatchClient
- type BatchClientConfig
- type Config
- type Entry
- type IngestLogsRequest
- type LogLevel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchSize ¶
func BatchSize(size int) func(*BatchClientConfig)
func EnqueueTimeout ¶
func EnqueueTimeout(timeout time.Duration) func(*BatchClientConfig)
func FlushInterval ¶
func FlushInterval(interval time.Duration) func(*BatchClientConfig)
Types ¶
type APIClientImpl ¶
type APIClientImpl struct {
// contains filtered or unexported fields
}
func NewAPIClient ¶
func NewAPIClient(cfg Config) (*APIClientImpl, error)
func (*APIClientImpl) IngestLogs ¶
func (a *APIClientImpl) IngestLogs(ctx context.Context, entries []Entry) error
type BatchClient ¶
type BatchClient struct {
// contains filtered or unexported fields
}
func NewBatchClient ¶
func NewBatchClient(client APIClient, opts ...func(*BatchClientConfig)) *BatchClient
func (*BatchClient) IngestLogs ¶
func (b *BatchClient) IngestLogs(ctx context.Context, entries []Entry) error
type BatchClientConfig ¶
type IngestLogsRequest ¶
Click to show internal directories.
Click to hide internal directories.