Documentation
¶
Index ¶
- type APIError
- type Alert
- type AlertChannel
- type AlertMetadata
- type Client
- func (c *Client) DeleteAlertChannel(channelID, channelsPath string) error
- func (c *Client) DeleteReadToken(projectID, readTokenID string) error
- func (c *Client) EnsureAlertHasChannelID(projectID, alertID, channelID string) error
- func (c *Client) ExecuteQueryWithToken(readToken string, request QueryRequest) (*QueryResponse, error)
- func (c *Client) FindAssignedAlertChannelID(projectID, alertID, preferredLabel, webhookURL string) (string, bool, error)
- func (c *Client) GetAlertChannelIDs(projectID, alertID string) ([]string, error)
- func (c *Client) ListAlerts(projectID string) ([]Alert, error)
- func (c *Client) ListProjects() ([]Project, error)
- func (c *Client) ProvisionReadToken(projectID string) (string, error)
- func (c *Client) UpsertAlertChannel(label, webhookURL, _ string) (*AlertChannel, string, error)
- type Configuration
- type Logfire
- func (l *Logfire) Actions() []core.Action
- func (l *Logfire) Cleanup(ctx core.IntegrationCleanupContext) error
- func (l *Logfire) Components() []core.Component
- func (l *Logfire) Configuration() []configuration.Field
- func (l *Logfire) Description() string
- func (l *Logfire) HandleAction(ctx core.IntegrationActionContext) error
- func (l *Logfire) HandleRequest(ctx core.HTTPRequestContext)
- func (l *Logfire) Icon() string
- func (l *Logfire) Instructions() string
- func (l *Logfire) Label() string
- func (l *Logfire) ListResources(resourceType string, ctx core.ListResourcesContext) ([]core.IntegrationResource, error)
- func (l *Logfire) Name() string
- func (l *Logfire) Sync(ctx core.SyncContext) error
- func (l *Logfire) Triggers() []core.Trigger
- type LogfireWebhookHandler
- func (h *LogfireWebhookHandler) Cleanup(ctx core.WebhookHandlerContext) error
- func (h *LogfireWebhookHandler) CompareConfig(a, b any) (bool, error)
- func (h *LogfireWebhookHandler) Merge(current, requested any) (any, bool, error)
- func (h *LogfireWebhookHandler) Setup(ctx core.WebhookHandlerContext) (any, error)
- type LogfireWebhookMetadata
- type Metadata
- type OnAlertReceived
- func (t *OnAlertReceived) Actions() []core.Action
- func (t *OnAlertReceived) Cleanup(ctx core.TriggerContext) error
- func (t *OnAlertReceived) Color() string
- func (t *OnAlertReceived) Configuration() []configuration.Field
- func (t *OnAlertReceived) Description() string
- func (t *OnAlertReceived) Documentation() string
- func (t *OnAlertReceived) ExampleData() map[string]any
- func (t *OnAlertReceived) HandleAction(ctx core.TriggerActionContext) (map[string]any, error)
- func (t *OnAlertReceived) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)
- func (t *OnAlertReceived) Icon() string
- func (t *OnAlertReceived) Label() string
- func (t *OnAlertReceived) Name() string
- func (t *OnAlertReceived) Setup(ctx core.TriggerContext) error
- type OnAlertReceivedNodeMetadata
- type Project
- type ProjectMetadata
- type QueryLogfire
- func (c *QueryLogfire) Actions() []core.Action
- func (c *QueryLogfire) Cancel(ctx core.ExecutionContext) error
- func (c *QueryLogfire) Cleanup(ctx core.SetupContext) error
- func (c *QueryLogfire) Color() string
- func (c *QueryLogfire) Configuration() []configuration.Field
- func (c *QueryLogfire) Description() string
- func (c *QueryLogfire) Documentation() string
- func (c *QueryLogfire) ExampleOutput() map[string]any
- func (c *QueryLogfire) Execute(ctx core.ExecutionContext) error
- func (c *QueryLogfire) HandleAction(ctx core.ActionContext) error
- func (c *QueryLogfire) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)
- func (c *QueryLogfire) Icon() string
- func (c *QueryLogfire) Label() string
- func (c *QueryLogfire) Name() string
- func (c *QueryLogfire) OutputChannels(configuration any) []core.OutputChannel
- func (c *QueryLogfire) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)
- func (c *QueryLogfire) Setup(ctx core.SetupContext) error
- type QueryLogfireConfiguration
- type QueryLogfireNodeMetadata
- type QueryRequest
- type QueryResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertChannel ¶
type AlertMetadata ¶
type Client ¶
type Client struct {
APIKey string
BaseURL string
APIBaseURL string
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(httpCtx core.HTTPContext, ctx core.IntegrationContext) (*Client, error)
func (*Client) DeleteAlertChannel ¶
func (*Client) DeleteReadToken ¶
func (*Client) EnsureAlertHasChannelID ¶
func (*Client) ExecuteQueryWithToken ¶
func (c *Client) ExecuteQueryWithToken(readToken string, request QueryRequest) (*QueryResponse, error)
func (*Client) FindAssignedAlertChannelID ¶
func (*Client) GetAlertChannelIDs ¶
func (*Client) ListProjects ¶
func (*Client) ProvisionReadToken ¶
ProvisionReadToken creates a read token for the given project and validates it. If validation fails, the created token is cleaned up.
func (*Client) UpsertAlertChannel ¶
func (c *Client) UpsertAlertChannel(label, webhookURL, _ string) (*AlertChannel, string, error)
type Configuration ¶
type Logfire ¶
type Logfire struct{}
func (*Logfire) Components ¶
func (*Logfire) Configuration ¶
func (l *Logfire) Configuration() []configuration.Field
func (*Logfire) Description ¶
func (*Logfire) HandleAction ¶
func (l *Logfire) HandleAction(ctx core.IntegrationActionContext) error
func (*Logfire) HandleRequest ¶
func (l *Logfire) HandleRequest(ctx core.HTTPRequestContext)
func (*Logfire) Instructions ¶
func (*Logfire) ListResources ¶
func (l *Logfire) ListResources(resourceType string, ctx core.ListResourcesContext) ([]core.IntegrationResource, error)
type LogfireWebhookHandler ¶
type LogfireWebhookHandler struct{}
func (*LogfireWebhookHandler) Cleanup ¶
func (h *LogfireWebhookHandler) Cleanup(ctx core.WebhookHandlerContext) error
func (*LogfireWebhookHandler) CompareConfig ¶
func (h *LogfireWebhookHandler) CompareConfig(a, b any) (bool, error)
func (*LogfireWebhookHandler) Merge ¶
func (h *LogfireWebhookHandler) Merge(current, requested any) (any, bool, error)
func (*LogfireWebhookHandler) Setup ¶
func (h *LogfireWebhookHandler) Setup(ctx core.WebhookHandlerContext) (any, error)
type LogfireWebhookMetadata ¶
type OnAlertReceived ¶
type OnAlertReceived struct{}
func (*OnAlertReceived) Actions ¶
func (t *OnAlertReceived) Actions() []core.Action
func (*OnAlertReceived) Cleanup ¶
func (t *OnAlertReceived) Cleanup(ctx core.TriggerContext) error
func (*OnAlertReceived) Color ¶
func (t *OnAlertReceived) Color() string
func (*OnAlertReceived) Configuration ¶
func (t *OnAlertReceived) Configuration() []configuration.Field
func (*OnAlertReceived) Description ¶
func (t *OnAlertReceived) Description() string
func (*OnAlertReceived) Documentation ¶
func (t *OnAlertReceived) Documentation() string
func (*OnAlertReceived) ExampleData ¶
func (t *OnAlertReceived) ExampleData() map[string]any
func (*OnAlertReceived) HandleAction ¶
func (t *OnAlertReceived) HandleAction(ctx core.TriggerActionContext) (map[string]any, error)
func (*OnAlertReceived) HandleWebhook ¶
func (t *OnAlertReceived) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)
func (*OnAlertReceived) Icon ¶
func (t *OnAlertReceived) Icon() string
func (*OnAlertReceived) Label ¶
func (t *OnAlertReceived) Label() string
func (*OnAlertReceived) Name ¶
func (t *OnAlertReceived) Name() string
func (*OnAlertReceived) Setup ¶
func (t *OnAlertReceived) Setup(ctx core.TriggerContext) error
type OnAlertReceivedNodeMetadata ¶
type OnAlertReceivedNodeMetadata struct {
Project *ProjectMetadata `json:"project,omitempty" mapstructure:"project"`
Alert *AlertMetadata `json:"alert,omitempty" mapstructure:"alert"`
}
type ProjectMetadata ¶
type QueryLogfire ¶
type QueryLogfire struct{}
func (*QueryLogfire) Actions ¶
func (c *QueryLogfire) Actions() []core.Action
func (*QueryLogfire) Cancel ¶
func (c *QueryLogfire) Cancel(ctx core.ExecutionContext) error
func (*QueryLogfire) Cleanup ¶
func (c *QueryLogfire) Cleanup(ctx core.SetupContext) error
func (*QueryLogfire) Color ¶
func (c *QueryLogfire) Color() string
func (*QueryLogfire) Configuration ¶
func (c *QueryLogfire) Configuration() []configuration.Field
func (*QueryLogfire) Description ¶
func (c *QueryLogfire) Description() string
func (*QueryLogfire) Documentation ¶
func (c *QueryLogfire) Documentation() string
func (*QueryLogfire) ExampleOutput ¶
func (c *QueryLogfire) ExampleOutput() map[string]any
func (*QueryLogfire) Execute ¶
func (c *QueryLogfire) Execute(ctx core.ExecutionContext) error
func (*QueryLogfire) HandleAction ¶
func (c *QueryLogfire) HandleAction(ctx core.ActionContext) error
func (*QueryLogfire) HandleWebhook ¶
func (c *QueryLogfire) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)
func (*QueryLogfire) Icon ¶
func (c *QueryLogfire) Icon() string
func (*QueryLogfire) Label ¶
func (c *QueryLogfire) Label() string
func (*QueryLogfire) Name ¶
func (c *QueryLogfire) Name() string
func (*QueryLogfire) OutputChannels ¶
func (c *QueryLogfire) OutputChannels(configuration any) []core.OutputChannel
func (*QueryLogfire) ProcessQueueItem ¶
func (c *QueryLogfire) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)
func (*QueryLogfire) Setup ¶
func (c *QueryLogfire) Setup(ctx core.SetupContext) error
type QueryLogfireConfiguration ¶
type QueryLogfireConfiguration struct {
SQL string `json:"sql" mapstructure:"sql"`
ProjectID string `json:"project" mapstructure:"project"`
TimeWindow string `json:"timeWindow,omitempty" mapstructure:"timeWindow"`
MinTimestamp string `json:"minTimestamp,omitempty" mapstructure:"minTimestamp"`
MaxTimestamp string `json:"maxTimestamp,omitempty" mapstructure:"maxTimestamp"`
Limit int `json:"limit,omitempty" mapstructure:"limit"`
RowOriented bool `json:"rowOriented,omitempty" mapstructure:"rowOriented"`
}
type QueryLogfireNodeMetadata ¶
type QueryLogfireNodeMetadata struct {
Project *ProjectMetadata `json:"project,omitempty" mapstructure:"project"`
}
type QueryRequest ¶
type QueryResponse ¶
Click to show internal directories.
Click to hide internal directories.