promtail

Documentation

Index

• func HandlerKinesis(ctx context.Context, kinesisEvent events.KinesisEvent) error
• func HandlerStream(ctx context.Context, ev *events.CloudwatchLogsEvent) error
• func NewHTTPClient(cfg *HttpClientConfig) *http.Client
• func NewLogger(logLevel string) *log.Logger
• func ProcessRecord(ctx context.Context, record events.KinesisEventRecord, pc Client) error
• func SetupArguments()
• type Client
• type HttpClientConfig
• type PromtailClient
  • func NewPromtailClient(cfg *PromtailClientConfig, log *log.Logger) *PromtailClient
• type PromtailClientConfig

Functions

func HandlerKinesis

func HandlerKinesis(ctx context.Context, kinesisEvent events.KinesisEvent) error

func HandlerStream

func HandlerStream(ctx context.Context, ev *events.CloudwatchLogsEvent) error

func NewHTTPClient

func NewHTTPClient(cfg *HttpClientConfig) *http.Client

func NewLogger

func NewLogger(logLevel string) *log.Logger

func ProcessRecord

func ProcessRecord(ctx context.Context, record events.KinesisEventRecord, pc Client) error

func SetupArguments

func SetupArguments()

Types

type Client

type Client interface {
	// contains filtered or unexported methods
}

type HttpClientConfig

type HttpClientConfig struct {
	// contains filtered or unexported fields
}

type PromtailClient

type PromtailClient struct {
	// contains filtered or unexported fields
}

Implements Client

func NewPromtailClient

func NewPromtailClient(cfg *PromtailClientConfig, log *log.Logger) *PromtailClient

type PromtailClientConfig

type PromtailClientConfig struct {
	// contains filtered or unexported fields
}