syncer

Documentation

Index

• func Main(runCtx context.Context, cfg *alertingv1.SyncerConfig) error
• func NewAlertingSyncerV1(ctx context.Context, serverConfig *alertingv1.SyncerConfig, ...) alertingv1.SyncerServer
• 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)

Functions

func Main

func Main(
	runCtx context.Context,
	cfg *alertingv1.SyncerConfig,
) error

func NewAlertingSyncerV1

func NewAlertingSyncerV1(
	ctx context.Context,
	serverConfig *alertingv1.SyncerConfig,
	mgmtClient managementv1.ManagementClient,
) alertingv1.SyncerServer

requires access to the alerting storage node requirements

Types

type AlertManagerSyncerV1

type AlertManagerSyncerV1 struct {
	alertingv1.UnsafeSyncerServer

	util.Initializer
	// contains filtered or unexported fields
}

func (*AlertManagerSyncerV1) Healthy

func (a *AlertManagerSyncerV1) Healthy(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

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) Ready

func (a *AlertManagerSyncerV1) Ready(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AlertManagerSyncerV1) Status

func (a *AlertManagerSyncerV1) Status(ctx context.Context, _ *emptypb.Empty) (*alertingv1.SyncerStatus, error)