cloudwatch

Documentation

Index

• Variables
• func NewLogStreamer(osWriters logging.OsWriters, nsConfig api.Config, appDetails app.Details) (admin.LogStreamer, error)
• type LogStreamer
  • func (l LogStreamer) Stream(ctx context.Context, options config.LogStreamOptions) error
• type MessageEmitter
• type Outputs

Variables

var (
	DefaultWatchInterval = 1 * time.Second
)

Functions

func NewLogStreamer

func NewLogStreamer(osWriters logging.OsWriters, nsConfig api.Config, appDetails app.Details) (admin.LogStreamer, error)

Types

type LogStreamer

type LogStreamer struct {
	OsWriters logging.OsWriters
	Details   app.Details
	Infra     Outputs
}

func (LogStreamer) Stream

func (l LogStreamer) Stream(ctx context.Context, options config.LogStreamOptions) error

type MessageEmitter

type MessageEmitter func(event cwltypes.FilteredLogEvent)

type Outputs

type Outputs struct {
	Region       string     `ns:"region"`
	LogReader    nsaws.User `ns:"log_reader"`
	LogGroupName string     `ns:"log_group_name"`
}