cloudwatch

Documentation

Index

• type Service
  • func (service Service) CreateLogGroup(groupName string) error
  • func (service Service) CreateLogStream(groupName, streamName string) error
  • func (service Service) GetAWSSession() (*session.Session, error)
  • func (service Service) WriteToLog(groupName, streamName string, entries []journal.Entry) error

Types

type Service

type Service struct {
	DB *data.Manager
}

Service encapsulates cloudwatch session and operations

func (Service) CreateLogGroup

func (service Service) CreateLogGroup(groupName string) error

CreateLogGroup creates a cloudwatch log group

func (Service) CreateLogStream

func (service Service) CreateLogStream(groupName, streamName string) error

CreateLogStream creates a cloudwatch log stream

func (Service) GetAWSSession

func (service Service) GetAWSSession() (*session.Session, error)

GetAWSSession gets an AWS session to use with an operation

func (Service) WriteToLog

func (service Service) WriteToLog(groupName, streamName string, entries []journal.Entry) error

WriteToLog writes the journal entries to the cloudwatch log stream for the tokens Might want to handle errors similarly to https://github.com/devops-genuine/opentelemetry-collector-contrib/blob/e38594a148080bd0b102281b830505c4acb1b736/exporter/awsemfexporter/cwlog_client.go#L84-L118