prometheus

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ListWorkspaces 

func ListWorkspaces(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(httpCtx core.HTTPContext, credentials *aws.Credentials, region string) *Client

func (*Client) CreateWorkspace 

func (c *Client) CreateWorkspace(input CreateWorkspaceInput) (*CreateWorkspaceResponse, error)

func (*Client) DeleteWorkspace 

func (c *Client) DeleteWorkspace(workspaceID string, clientToken string) error

func (*Client) DescribeWorkspace 

func (c *Client) DescribeWorkspace(workspaceID string) (*WorkspaceDescription, error)

func (*Client) ListWorkspaces 

func (c *Client) ListWorkspaces(alias string) ([]WorkspaceSummary, error)

func (*Client) QueryMetrics 

func (c *Client) QueryMetrics(input QueryMetricsInput) (map[string]any, error)

func (*Client) QueryRangeMetrics 

func (c *Client) QueryRangeMetrics(input QueryRangeMetricsInput) (map[string]any, error)

func (*Client) UpdateWorkspaceAlias 

func (c *Client) UpdateWorkspaceAlias(workspaceID string, alias string, clientToken string) error

type CreateWorkspace 

type CreateWorkspace struct{}

func (*CreateWorkspace) Cancel 

func (c *CreateWorkspace) Cancel(ctx core.ExecutionContext) error

func (*CreateWorkspace) Cleanup 

func (c *CreateWorkspace) Cleanup(ctx core.SetupContext) error

func (*CreateWorkspace) Color 

func (c *CreateWorkspace) Color() string

func (*CreateWorkspace) Configuration 

func (c *CreateWorkspace) Configuration() []configuration.Field

func (*CreateWorkspace) Description 

func (c *CreateWorkspace) Description() string

func (*CreateWorkspace) Documentation 

func (c *CreateWorkspace) Documentation() string

func (*CreateWorkspace) ExampleOutput 

func (c *CreateWorkspace) ExampleOutput() map[string]any

func (*CreateWorkspace) Execute 

func (c *CreateWorkspace) Execute(ctx core.ExecutionContext) error

func (*CreateWorkspace) HandleHook 

func (c *CreateWorkspace) HandleHook(ctx core.ActionHookContext) error

func (*CreateWorkspace) HandleWebhook 

func (c *CreateWorkspace) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*CreateWorkspace) Hooks 

func (c *CreateWorkspace) Hooks() []core.Hook

func (*CreateWorkspace) Icon 

func (c *CreateWorkspace) Icon() string

func (*CreateWorkspace) Label 

func (c *CreateWorkspace) Label() string

func (*CreateWorkspace) Name 

func (c *CreateWorkspace) Name() string

func (*CreateWorkspace) OutputChannels 

func (c *CreateWorkspace) OutputChannels(configuration any) []core.OutputChannel

func (*CreateWorkspace) ProcessQueueItem 

func (c *CreateWorkspace) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*CreateWorkspace) Setup 

func (c *CreateWorkspace) Setup(ctx core.SetupContext) error

type CreateWorkspaceConfiguration 

type CreateWorkspaceConfiguration struct {
	Region      string       `json:"region" mapstructure:"region"`
	Alias       string       `json:"alias" mapstructure:"alias"`
	KMSKeyArn   string       `json:"kmsKeyArn" mapstructure:"kmsKeyArn"`
	ClientToken string       `json:"clientToken" mapstructure:"clientToken"`
	Tags        []common.Tag `json:"tags" mapstructure:"tags"`
}

type CreateWorkspaceInput 

type CreateWorkspaceInput struct {
	Alias       string
	ClientToken string
	KMSKeyArn   string
	Tags        []common.Tag
}

type CreateWorkspaceResponse 

type CreateWorkspaceResponse struct {
	Alias       string            `json:"alias,omitempty"`
	Arn         string            `json:"arn"`
	KMSKeyArn   string            `json:"kmsKeyArn,omitempty"`
	Status      WorkspaceStatus   `json:"status"`
	Tags        map[string]string `json:"tags,omitempty"`
	WorkspaceID string            `json:"workspaceId"`
}

type DeleteWorkspace 

type DeleteWorkspace struct{}

func (*DeleteWorkspace) Cancel 

func (c *DeleteWorkspace) Cancel(ctx core.ExecutionContext) error

func (*DeleteWorkspace) Cleanup 

func (c *DeleteWorkspace) Cleanup(ctx core.SetupContext) error

func (*DeleteWorkspace) Color 

func (c *DeleteWorkspace) Color() string

func (*DeleteWorkspace) Configuration 

func (c *DeleteWorkspace) Configuration() []configuration.Field

func (*DeleteWorkspace) Description 

func (c *DeleteWorkspace) Description() string

func (*DeleteWorkspace) Documentation 

func (c *DeleteWorkspace) Documentation() string

func (*DeleteWorkspace) ExampleOutput 

func (c *DeleteWorkspace) ExampleOutput() map[string]any

func (*DeleteWorkspace) Execute 

func (c *DeleteWorkspace) Execute(ctx core.ExecutionContext) error

func (*DeleteWorkspace) HandleHook 

func (c *DeleteWorkspace) HandleHook(ctx core.ActionHookContext) error

func (*DeleteWorkspace) HandleWebhook 

func (c *DeleteWorkspace) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DeleteWorkspace) Hooks 

func (c *DeleteWorkspace) Hooks() []core.Hook

func (*DeleteWorkspace) Icon 

func (c *DeleteWorkspace) Icon() string

func (*DeleteWorkspace) Label 

func (c *DeleteWorkspace) Label() string

func (*DeleteWorkspace) Name 

func (c *DeleteWorkspace) Name() string

func (*DeleteWorkspace) OutputChannels 

func (c *DeleteWorkspace) OutputChannels(configuration any) []core.OutputChannel

func (*DeleteWorkspace) ProcessQueueItem 

func (c *DeleteWorkspace) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DeleteWorkspace) Setup 

func (c *DeleteWorkspace) Setup(ctx core.SetupContext) error

type GetWorkspace 

type GetWorkspace struct{}

func (*GetWorkspace) Cancel 

func (c *GetWorkspace) Cancel(ctx core.ExecutionContext) error

func (*GetWorkspace) Cleanup 

func (c *GetWorkspace) Cleanup(ctx core.SetupContext) error

func (*GetWorkspace) Color 

func (c *GetWorkspace) Color() string

func (*GetWorkspace) Configuration 

func (c *GetWorkspace) Configuration() []configuration.Field

func (*GetWorkspace) Description 

func (c *GetWorkspace) Description() string

func (*GetWorkspace) Documentation 

func (c *GetWorkspace) Documentation() string

func (*GetWorkspace) ExampleOutput 

func (c *GetWorkspace) ExampleOutput() map[string]any

func (*GetWorkspace) Execute 

func (c *GetWorkspace) Execute(ctx core.ExecutionContext) error

func (*GetWorkspace) HandleHook 

func (c *GetWorkspace) HandleHook(ctx core.ActionHookContext) error

func (*GetWorkspace) HandleWebhook 

func (c *GetWorkspace) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*GetWorkspace) Hooks 

func (c *GetWorkspace) Hooks() []core.Hook

func (*GetWorkspace) Icon 

func (c *GetWorkspace) Icon() string

func (*GetWorkspace) Label 

func (c *GetWorkspace) Label() string

func (*GetWorkspace) Name 

func (c *GetWorkspace) Name() string

func (*GetWorkspace) OutputChannels 

func (c *GetWorkspace) OutputChannels(configuration any) []core.OutputChannel

func (*GetWorkspace) ProcessQueueItem 

func (c *GetWorkspace) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*GetWorkspace) Setup 

func (c *GetWorkspace) Setup(ctx core.SetupContext) error

type Query 

type Query struct{}

func (*Query) Cancel 

func (c *Query) Cancel(ctx core.ExecutionContext) error

func (*Query) Cleanup 

func (c *Query) Cleanup(ctx core.SetupContext) error

func (*Query) Color 

func (c *Query) Color() string

func (*Query) Configuration 

func (c *Query) Configuration() []configuration.Field

func (*Query) Description 

func (c *Query) Description() string

func (*Query) Documentation 

func (c *Query) Documentation() string

func (*Query) ExampleOutput 

func (c *Query) ExampleOutput() map[string]any

func (*Query) Execute 

func (c *Query) Execute(ctx core.ExecutionContext) error

func (*Query) HandleHook 

func (c *Query) HandleHook(ctx core.ActionHookContext) error

func (*Query) HandleWebhook 

func (c *Query) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*Query) Hooks 

func (c *Query) Hooks() []core.Hook

func (*Query) Icon 

func (c *Query) Icon() string

func (*Query) Label 

func (c *Query) Label() string

func (*Query) Name 

func (c *Query) Name() string

func (*Query) OutputChannels 

func (c *Query) OutputChannels(configuration any) []core.OutputChannel

func (*Query) ProcessQueueItem 

func (c *Query) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*Query) Setup 

func (c *Query) Setup(ctx core.SetupContext) error

type QueryConfiguration 

type QueryConfiguration struct {
	Region                    string `json:"region" mapstructure:"region"`
	WorkspaceID               string `json:"workspace" mapstructure:"workspace"`
	Query                     string `json:"query" mapstructure:"query"`
	Time                      string `json:"time" mapstructure:"time"`
	QueryOptionsConfiguration `mapstructure:",squash"`
}

type QueryMetricsInput 

type QueryMetricsInput struct {
	WorkspaceID                         string
	Query                               string
	Time                                string
	Timeout                             string
	MaxSamplesProcessedWarningThreshold int
	MaxSamplesProcessedErrorThreshold   int
}

type QueryOptionsConfiguration 

type QueryOptionsConfiguration struct {
	Timeout                             string `json:"timeout" mapstructure:"timeout"`
	MaxSamplesProcessedWarningThreshold int    `json:"maxSamplesProcessedWarningThreshold" mapstructure:"maxSamplesProcessedWarningThreshold"`
	MaxSamplesProcessedErrorThreshold   int    `json:"maxSamplesProcessedErrorThreshold" mapstructure:"maxSamplesProcessedErrorThreshold"`
}

type QueryRange 

type QueryRange struct{}

func (*QueryRange) Cancel 

func (c *QueryRange) Cancel(ctx core.ExecutionContext) error

func (*QueryRange) Cleanup 

func (c *QueryRange) Cleanup(ctx core.SetupContext) error

func (*QueryRange) Color 

func (c *QueryRange) Color() string

func (*QueryRange) Configuration 

func (c *QueryRange) Configuration() []configuration.Field

func (*QueryRange) Description 

func (c *QueryRange) Description() string

func (*QueryRange) Documentation 

func (c *QueryRange) Documentation() string

func (*QueryRange) ExampleOutput 

func (c *QueryRange) ExampleOutput() map[string]any

func (*QueryRange) Execute 

func (c *QueryRange) Execute(ctx core.ExecutionContext) error

func (*QueryRange) HandleHook 

func (c *QueryRange) HandleHook(ctx core.ActionHookContext) error

func (*QueryRange) HandleWebhook 

func (c *QueryRange) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*QueryRange) Hooks 

func (c *QueryRange) Hooks() []core.Hook

func (*QueryRange) Icon 

func (c *QueryRange) Icon() string

func (*QueryRange) Label 

func (c *QueryRange) Label() string

func (*QueryRange) Name 

func (c *QueryRange) Name() string

func (*QueryRange) OutputChannels 

func (c *QueryRange) OutputChannels(configuration any) []core.OutputChannel

func (*QueryRange) ProcessQueueItem 

func (c *QueryRange) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*QueryRange) Setup 

func (c *QueryRange) Setup(ctx core.SetupContext) error

type QueryRangeConfiguration 

type QueryRangeConfiguration struct {
	Region                    string `json:"region" mapstructure:"region"`
	WorkspaceID               string `json:"workspace" mapstructure:"workspace"`
	Query                     string `json:"query" mapstructure:"query"`
	Start                     string `json:"start" mapstructure:"start"`
	End                       string `json:"end" mapstructure:"end"`
	Step                      string `json:"step" mapstructure:"step"`
	QueryOptionsConfiguration `mapstructure:",squash"`
}

type QueryRangeMetricsInput 

type QueryRangeMetricsInput struct {
	WorkspaceID                         string
	Query                               string
	Start                               string
	End                                 string
	Step                                string
	Timeout                             string
	MaxSamplesProcessedWarningThreshold int
	MaxSamplesProcessedErrorThreshold   int
}

type UpdateWorkspace 

type UpdateWorkspace struct{}

func (*UpdateWorkspace) Cancel 

func (c *UpdateWorkspace) Cancel(ctx core.ExecutionContext) error

func (*UpdateWorkspace) Cleanup 

func (c *UpdateWorkspace) Cleanup(ctx core.SetupContext) error

func (*UpdateWorkspace) Color 

func (c *UpdateWorkspace) Color() string

func (*UpdateWorkspace) Configuration 

func (c *UpdateWorkspace) Configuration() []configuration.Field

func (*UpdateWorkspace) Description 

func (c *UpdateWorkspace) Description() string

func (*UpdateWorkspace) Documentation 

func (c *UpdateWorkspace) Documentation() string

func (*UpdateWorkspace) ExampleOutput 

func (c *UpdateWorkspace) ExampleOutput() map[string]any

func (*UpdateWorkspace) Execute 

func (c *UpdateWorkspace) Execute(ctx core.ExecutionContext) error

func (*UpdateWorkspace) HandleHook 

func (c *UpdateWorkspace) HandleHook(ctx core.ActionHookContext) error

func (*UpdateWorkspace) HandleWebhook 

func (c *UpdateWorkspace) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*UpdateWorkspace) Hooks 

func (c *UpdateWorkspace) Hooks() []core.Hook

func (*UpdateWorkspace) Icon 

func (c *UpdateWorkspace) Icon() string

func (*UpdateWorkspace) Label 

func (c *UpdateWorkspace) Label() string

func (*UpdateWorkspace) Name 

func (c *UpdateWorkspace) Name() string

func (*UpdateWorkspace) OutputChannels 

func (c *UpdateWorkspace) OutputChannels(configuration any) []core.OutputChannel

func (*UpdateWorkspace) ProcessQueueItem 

func (c *UpdateWorkspace) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*UpdateWorkspace) Setup 

func (c *UpdateWorkspace) Setup(ctx core.SetupContext) error

type UpdateWorkspaceConfiguration 

type UpdateWorkspaceConfiguration struct {
	Region      string `json:"region" mapstructure:"region"`
	WorkspaceID string `json:"workspace" mapstructure:"workspace"`
	Alias       string `json:"alias" mapstructure:"alias"`
	ClientToken string `json:"clientToken" mapstructure:"clientToken"`
}

type WorkspaceDescription 

type WorkspaceDescription struct {
	WorkspaceSummary
	PrometheusEndpoint string `json:"prometheusEndpoint,omitempty"`
}

type WorkspaceNodeMetadata 

type WorkspaceNodeMetadata struct {
	Region         string `json:"region" mapstructure:"region"`
	WorkspaceID    string `json:"workspaceId" mapstructure:"workspaceId"`
	WorkspaceAlias string `json:"workspaceAlias" mapstructure:"workspaceAlias"`
}

type WorkspaceStatus 

type WorkspaceStatus struct {
	StatusCode string `json:"statusCode"`
}

type WorkspaceSummary 

type WorkspaceSummary struct {
	Alias       string            `json:"alias,omitempty"`
	Arn         string            `json:"arn"`
	CreatedAt   common.FloatTime  `json:"createdAt,omitempty"`
	KMSKeyArn   string            `json:"kmsKeyArn,omitempty"`
	Status      WorkspaceStatus   `json:"status"`
	Tags        map[string]string `json:"tags,omitempty"`
	WorkspaceID string            `json:"workspaceId"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.