Documentation
¶
Index ¶
- type BatchLogPusher
- func (p *BatchLogPusher) Add(ctx context.Context, event awstypes.InputLogEvent) error
- func (p *BatchLogPusher) CreateLogGroup(ctx context.Context, group string) error
- func (p *BatchLogPusher) CreateLogStream(ctx context.Context, group, stream string) error
- func (p *BatchLogPusher) Flush(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchLogPusher ¶
type BatchLogPusher struct {
// contains filtered or unexported fields
}
BatchLogPusher cwLogsClient for handling log events. @TODO convert into lib reused by fluentbit-cloudwatchlogs
func NewBatchLogPusher ¶
func NewBatchLogPusher(ctx context.Context, logger log.Logger, cwLogsClient types.CloudwatchLogsInterface, group, stream string, batchSize int) *BatchLogPusher
NewBatchLogPusher creates a new batch log pusher.
func (*BatchLogPusher) Add ¶
func (p *BatchLogPusher) Add(ctx context.Context, event awstypes.InputLogEvent) error
Add event to the cwLogsClient.
func (*BatchLogPusher) CreateLogGroup ¶
func (p *BatchLogPusher) CreateLogGroup(ctx context.Context, group string) error
CreateLogGroup will attempt to create a log group and not return an error if it already exists.
func (*BatchLogPusher) CreateLogStream ¶
func (p *BatchLogPusher) CreateLogStream(ctx context.Context, group, stream string) error
CreateLogStream will attempt to create a log stream and not return an error if it already exists.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.