endpoints

Documentation

Index

• Variables
• type EndpointServerComponent
  • func NewEndpointServerComponent(ctx context.Context, logger *slog.Logger, ...) *EndpointServerComponent
  • func (e *EndpointServerComponent) CreateAlertEndpoint(ctx context.Context, req *alertingv1.AlertEndpoint) (*corev1.Reference, error)
  • func (e *EndpointServerComponent) DeleteAlertEndpoint(ctx context.Context, req *alertingv1.DeleteAlertEndpointRequest) (*alertingv1.ConditionReferenceList, error)
  • func (e *EndpointServerComponent) GetAlertEndpoint(ctx context.Context, ref *corev1.Reference) (*alertingv1.AlertEndpoint, error)
  • func (e *EndpointServerComponent) Healthy() bool
  • func (e *EndpointServerComponent) Initialize(conf EndpointServerConfiguration)
  • func (e *EndpointServerComponent) ListAlertEndpoints(ctx context.Context, req *alertingv1.ListAlertEndpointsRequest) (*alertingv1.AlertEndpointList, error)
  • func (e *EndpointServerComponent) Name() string
  • func (e *EndpointServerComponent) Ready() bool
  • func (e *EndpointServerComponent) SetConfig(conf server.Config)
  • func (e *EndpointServerComponent) Status() server.Status
  • func (e *EndpointServerComponent) Sync(_ context.Context, _ alertingSync.SyncInfo) error
  • func (e *EndpointServerComponent) ToggleNotifications(ctx context.Context, req *alertingv1.ToggleRequest) (*emptypb.Empty, error)
  • func (e *EndpointServerComponent) UpdateAlertEndpoint(ctx context.Context, req *alertingv1.UpdateAlertEndpointRequest) (*alertingv1.ConditionReferenceList, error)
• type EndpointServerConfiguration

Variables

var (
	RetryTestEdnpoint = 1 * time.Second
)

Types

type EndpointServerComponent

type EndpointServerComponent struct {
	alertingv1.UnsafeAlertEndpointsServer

	util.Initializer

	server.Config
	// contains filtered or unexported fields
}

func NewEndpointServerComponent

func NewEndpointServerComponent(
	ctx context.Context,
	logger *slog.Logger,
	notifications *notifications.NotificationServerComponent,
) *EndpointServerComponent

func (*EndpointServerComponent) CreateAlertEndpoint

func (e *EndpointServerComponent) CreateAlertEndpoint(ctx context.Context, req *alertingv1.AlertEndpoint) (*corev1.Reference, error)

func (*EndpointServerComponent) DeleteAlertEndpoint

func (e *EndpointServerComponent) DeleteAlertEndpoint(ctx context.Context, req *alertingv1.DeleteAlertEndpointRequest) (*alertingv1.ConditionReferenceList, error)

func (*EndpointServerComponent) GetAlertEndpoint

func (e *EndpointServerComponent) GetAlertEndpoint(ctx context.Context, ref *corev1.Reference) (*alertingv1.AlertEndpoint, error)

func (*EndpointServerComponent) Healthy

func (e *EndpointServerComponent) Healthy() bool

func (*EndpointServerComponent) Initialize

func (e *EndpointServerComponent) Initialize(conf EndpointServerConfiguration)

func (*EndpointServerComponent) ListAlertEndpoints

func (e *EndpointServerComponent) ListAlertEndpoints(
	ctx context.Context,
	req *alertingv1.ListAlertEndpointsRequest,
) (*alertingv1.AlertEndpointList, error)

func (*EndpointServerComponent) Name

func (e *EndpointServerComponent) Name() string

func (*EndpointServerComponent) Ready

func (e *EndpointServerComponent) Ready() bool

func (*EndpointServerComponent) SetConfig

func (e *EndpointServerComponent) SetConfig(conf server.Config)

func (*EndpointServerComponent) Status

func (e *EndpointServerComponent) Status() server.Status

func (*EndpointServerComponent) Sync

func (e *EndpointServerComponent) Sync(_ context.Context, _ alertingSync.SyncInfo) error

func (*EndpointServerComponent) ToggleNotifications

func (e *EndpointServerComponent) ToggleNotifications(ctx context.Context, req *alertingv1.ToggleRequest) (*emptypb.Empty, error)

func (*EndpointServerComponent) UpdateAlertEndpoint

func (e *EndpointServerComponent) UpdateAlertEndpoint(ctx context.Context, req *alertingv1.UpdateAlertEndpointRequest) (*alertingv1.ConditionReferenceList, error)

type EndpointServerConfiguration

type EndpointServerConfiguration struct {
	spec.EndpointStorage
	spec.ConditionStorage
	spec.RouterStorage
	spec.HashRing
}