Documentation
¶
Index ¶
Constants ¶
View Source
const ( // debugging period OneHourPeriodInSeconds int32 = 60 * 60 // 60 seconds * 60 minutes DailyPeriodInSeconds int32 = 60 * 60 * 24 // 60 seconds * 60 minutes * 24 hours Last24Hours TimePeriod = "last24Hours" LastWeek TimePeriod = "lastWeek" LastMonth TimePeriod = "lastMonth" LastYear TimePeriod = "lastYear" )
Variables ¶
This section is empty.
Functions ¶
func GetTimeWindow ¶ added in v0.4.0
func GetTimeWindow(endTime time.Time, desiredPeriod TimePeriod) (types.CloudWatchTimeWindow, error)
GetTimeWindow calculates CloudWatch time windows for different periods based on a end time
Types ¶
type MetricService ¶
type MetricService struct {
// contains filtered or unexported fields
}
func NewMetricService ¶
func NewMetricService(client *cloudwatch.Client) *MetricService
func (*MetricService) ProcessProvisionedCluster ¶ added in v0.4.0
func (ms *MetricService) ProcessProvisionedCluster(ctx context.Context, cluster kafkatypes.Cluster, followerFetching bool, timeWindow types.CloudWatchTimeWindow) (*types.ClusterMetrics, error)
ProcessProvisionedCluster processes metrics for provisioned aggregated across all brokers in a cluster
func (*MetricService) ProcessServerlessCluster ¶ added in v0.4.0
func (ms *MetricService) ProcessServerlessCluster(ctx context.Context, cluster kafkatypes.Cluster, timeWindow types.CloudWatchTimeWindow) (*types.ClusterMetrics, error)
ProcessServerlessCluster processes metrics for serverless aggregated across all topics in a cluster
type TimePeriod ¶ added in v0.4.0
type TimePeriod string
Source Files
Click to show internal directories.
Click to hide internal directories.