cloudwatch

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL