cloudwatch_log_group

Jul 2, 2025

Changes in this version

type CloudWatchLogGroupCollectionState

+ Granularity time.Duration

+ func (s *CloudWatchLogGroupCollectionState) MigrateFromLegacyState(bytes []byte) error

+ func (s *CloudWatchLogGroupCollectionState) OnCollectionComplete() error

+ func (s *CloudWatchLogGroupCollectionState) Validate() error

+ type CloudWatchLogGroupCollectionStateLegacy struct

+ LastModifiedTime time.Time

+ LogStreams map[string]*collection_state.TimeRangeCollectionStateLegacy

May 23, 2025

Changes in this version

+ const AwsCloudwatchLogGroupSourceIdentifier

+ func NewCloudWatchLogGroupCollectionState() collection_state.CollectionState[*AwsCloudWatchLogGroupSourceConfig]

+ type AwsCloudWatchLogGroupSource struct

+ func (s *AwsCloudWatchLogGroupSource) Clear() error

+ func (s *AwsCloudWatchLogGroupSource) Collect(ctx context.Context) error

+ func (s *AwsCloudWatchLogGroupSource) Identifier() string

+ func (s *AwsCloudWatchLogGroupSource) Init(ctx context.Context, params *row_source.RowSourceParams, ...) error

+ type AwsCloudWatchLogGroupSourceConfig struct

+ LogGroupName string

+ LogStreamNames []string

+ Region *string

+ func (c *AwsCloudWatchLogGroupSourceConfig) Identifier() string

+ func (c *AwsCloudWatchLogGroupSourceConfig) Validate() error

+ type CloudWatchLogGroupCollectionState struct

+ LastModifiedTime time.Time

+ LogStreams map[string]*collection_state.TimeRangeCollectionStateImpl

+ func (s *CloudWatchLogGroupCollectionState) Clear()

+ func (s *CloudWatchLogGroupCollectionState) GetConfig() *AwsCloudWatchLogGroupSourceConfig

+ func (s *CloudWatchLogGroupCollectionState) GetEndTime() time.Time

+ func (s *CloudWatchLogGroupCollectionState) GetEndTimeForStream(logStreamName string) time.Time

+ func (s *CloudWatchLogGroupCollectionState) GetFromTime() time.Time

+ func (s *CloudWatchLogGroupCollectionState) GetGranularity() time.Duration

+ func (s *CloudWatchLogGroupCollectionState) GetStartTime() time.Time

+ func (s *CloudWatchLogGroupCollectionState) GetStartTimeForStream(logStreamName string) time.Time

+ func (s *CloudWatchLogGroupCollectionState) GetToTime() time.Time

+ func (s *CloudWatchLogGroupCollectionState) Init(config *AwsCloudWatchLogGroupSourceConfig, path string) error

+ func (s *CloudWatchLogGroupCollectionState) IsEmpty() bool

+ func (s *CloudWatchLogGroupCollectionState) OnCollected(logStreamName string, timestamp time.Time) error

+ func (s *CloudWatchLogGroupCollectionState) Save() error

+ func (s *CloudWatchLogGroupCollectionState) SetConfig(config *AwsCloudWatchLogGroupSourceConfig)

+ func (s *CloudWatchLogGroupCollectionState) SetEndTime(endTime time.Time)

+ func (s *CloudWatchLogGroupCollectionState) SetGranularity(granularity time.Duration)

+ func (s *CloudWatchLogGroupCollectionState) ShouldCollect(logStreamName string, timestamp time.Time) bool