Documentation
¶
Index ¶
- func NewAlertingSyncerV1(ctx context.Context, serverConfig *alertingv1.SyncerConfig, ...) alertingv1.SyncerServer
- func NewLFUMessageCache(lub int) messageCache[alertingv1.OpniSeverity, *alertingv1.MessageInstance]
- func ParseIncomingWebhookMessage(req *http.Request) (config.WebhookMessage, error)
- func StartOpniEmbeddedServer(ctx context.Context, opniAddr string) *http.Server
- type AlertManagerSyncerV1
- func (a *AlertManagerSyncerV1) Healthy(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
- func (a *AlertManagerSyncerV1) Initialize(ctx context.Context, mgmtClient managementv1.ManagementClient)
- func (a *AlertManagerSyncerV1) PutConfig(ctx context.Context, incomingConfig *alertingv1.PutConfigRequest) (*emptypb.Empty, error)
- func (a *AlertManagerSyncerV1) Ready(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
- func (a *AlertManagerSyncerV1) Status(ctx context.Context, _ *emptypb.Empty) (*alertingv1.SyncerStatus, error)
- type EmbeddedServer
- type MessageMetadata
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAlertingSyncerV1 ¶
func NewAlertingSyncerV1( ctx context.Context, serverConfig *alertingv1.SyncerConfig, mgmtClient managementv1.ManagementClient, ) alertingv1.SyncerServer
requires access to the alerting storage node requirements
func NewLFUMessageCache ¶ added in v0.9.0
func NewLFUMessageCache(lub int) messageCache[alertingv1.OpniSeverity, *alertingv1.MessageInstance]
func ParseIncomingWebhookMessage ¶ added in v0.9.0
func ParseIncomingWebhookMessage(req *http.Request) (config.WebhookMessage, error)
ParseIncomingWebhookMessage return non-pointer for performance reasons
Types ¶
type AlertManagerSyncerV1 ¶
type AlertManagerSyncerV1 struct { alertingv1.UnsafeSyncerServer util.Initializer // contains filtered or unexported fields }
func (*AlertManagerSyncerV1) Initialize ¶
func (a *AlertManagerSyncerV1) Initialize( ctx context.Context, mgmtClient managementv1.ManagementClient, )
func (*AlertManagerSyncerV1) PutConfig ¶
func (a *AlertManagerSyncerV1) PutConfig(ctx context.Context, incomingConfig *alertingv1.PutConfigRequest) (*emptypb.Empty, error)
func (*AlertManagerSyncerV1) Status ¶
func (a *AlertManagerSyncerV1) Status(ctx context.Context, _ *emptypb.Empty) (*alertingv1.SyncerStatus, error)
type EmbeddedServer ¶ added in v0.9.0
type EmbeddedServer struct {
// contains filtered or unexported fields
}
Embedded Server handles all incoming webhook requests from the AlertManager
func NewEmbeddedServer ¶ added in v0.9.0
func NewEmbeddedServer( lg *zap.SugaredLogger, lub int, ) *EmbeddedServer
Click to show internal directories.
Click to hide internal directories.