service

package

v1.0.0-beta.227 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

Index ¶

Constants
func ValidateRuleChannels[I notification.CreateRuleInput | notification.UpdateRuleInput](ctx context.Context, s Service) func(input I) error
type Config
type Service
- func New(config Config) (*Service, error)

Constants ¶

const (
	ChannelIDMetadataKey = "om-channel-id"
)

Variables ¶

This section is empty.

Functions ¶

func ValidateRuleChannels ¶

func ValidateRuleChannels[I notification.CreateRuleInput | notification.UpdateRuleInput](ctx context.Context, s Service) func(input I) error

Types ¶

type Config ¶

type Config struct {
	FeatureConnector feature.FeatureConnector

	Adapter      notification.Repository
	Webhook      webhook.Handler
	EventHandler notification.EventHandler

	Logger *slog.Logger
}

type Service ¶

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

func New ¶

func New(config Config) (*Service, error)

func (Service) CreateChannel ¶

func (s Service) CreateChannel(ctx context.Context, params notification.CreateChannelInput) (*notification.Channel, error)

func (Service) CreateEvent ¶

func (s Service) CreateEvent(ctx context.Context, params notification.CreateEventInput) (*notification.Event, error)

func (Service) CreateRule ¶

func (s Service) CreateRule(ctx context.Context, params notification.CreateRuleInput) (*notification.Rule, error)

func (Service) DeleteChannel ¶

func (s Service) DeleteChannel(ctx context.Context, params notification.DeleteChannelInput) error

func (Service) DeleteRule ¶

func (s Service) DeleteRule(ctx context.Context, params notification.DeleteRuleInput) error

func (Service) GetChannel ¶

func (s Service) GetChannel(ctx context.Context, params notification.GetChannelInput) (*notification.Channel, error)

func (Service) GetEvent ¶

func (s Service) GetEvent(ctx context.Context, params notification.GetEventInput) (*notification.Event, error)

func (Service) GetEventDeliveryStatus ¶

func (s Service) GetEventDeliveryStatus(ctx context.Context, params notification.GetEventDeliveryStatusInput) (*notification.EventDeliveryStatus, error)

func (Service) GetRule ¶

func (s Service) GetRule(ctx context.Context, params notification.GetRuleInput) (*notification.Rule, error)

func (Service) ListChannels ¶

func (s Service) ListChannels(ctx context.Context, params notification.ListChannelsInput) (notification.ListChannelsResult, error)

func (Service) ListEvents ¶

func (s Service) ListEvents(ctx context.Context, params notification.ListEventsInput) (notification.ListEventsResult, error)

func (Service) ListEventsDeliveryStatus ¶

func (s Service) ListEventsDeliveryStatus(ctx context.Context, params notification.ListEventsDeliveryStatusInput) (notification.ListEventsDeliveryStatusResult, error)

func (Service) ListFeature ¶

func (s Service) ListFeature(ctx context.Context, namespace string, features ...string) ([]feature.Feature, error)

func (Service) ListRules ¶

func (s Service) ListRules(ctx context.Context, params notification.ListRulesInput) (notification.ListRulesResult, error)

func (Service) ResendEvent ¶

func (s Service) ResendEvent(ctx context.Context, params notification.ResendEventInput) error

func (Service) UpdateChannel ¶

func (s Service) UpdateChannel(ctx context.Context, params notification.UpdateChannelInput) (*notification.Channel, error)

func (Service) UpdateEventDeliveryStatus ¶

func (s Service) UpdateEventDeliveryStatus(ctx context.Context, params notification.UpdateEventDeliveryStatusInput) (*notification.EventDeliveryStatus, error)

func (Service) UpdateRule ¶

func (s Service) UpdateRule(ctx context.Context, params notification.UpdateRuleInput) (*notification.Rule, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL