service

Documentation

Index

• Constants
• type Config
• type Service
  • func New(config Config) (*Service, error)
  • func (s Service) Close() error
  • func (s Service) CreateChannel(ctx context.Context, params notification.CreateChannelInput) (*notification.Channel, error)
  • func (s Service) CreateEvent(ctx context.Context, params notification.CreateEventInput) (*notification.Event, error)
  • func (s Service) CreateRule(ctx context.Context, params notification.CreateRuleInput) (*notification.Rule, error)
  • func (s Service) DeleteChannel(ctx context.Context, params notification.DeleteChannelInput) error
  • func (s Service) DeleteRule(ctx context.Context, params notification.DeleteRuleInput) error
  • func (s Service) GetChannel(ctx context.Context, params notification.GetChannelInput) (*notification.Channel, error)
  • func (s Service) GetEvent(ctx context.Context, params notification.GetEventInput) (*notification.Event, error)
  • func (s Service) GetEventDeliveryStatus(ctx context.Context, params notification.GetEventDeliveryStatusInput) (*notification.EventDeliveryStatus, error)
  • func (s Service) GetRule(ctx context.Context, params notification.GetRuleInput) (*notification.Rule, error)
  • func (s Service) ListChannels(ctx context.Context, params notification.ListChannelsInput) (notification.ListChannelsResult, error)
  • func (s Service) ListEvents(ctx context.Context, params notification.ListEventsInput) (notification.ListEventsResult, error)
  • func (s Service) ListEventsDeliveryStatus(ctx context.Context, params notification.ListEventsDeliveryStatusInput) (notification.ListEventsDeliveryStatusResult, error)
  • func (s Service) ListFeature(ctx context.Context, namespace string, features ...string) ([]productcatalog.Feature, error)
  • func (s Service) ListRules(ctx context.Context, params notification.ListRulesInput) (notification.ListRulesResult, error)
  • func (s Service) UpdateChannel(ctx context.Context, params notification.UpdateChannelInput) (*notification.Channel, error)
  • func (s Service) UpdateEventDeliveryStatus(ctx context.Context, params notification.UpdateEventDeliveryStatusInput) (*notification.EventDeliveryStatus, error)
  • func (s Service) UpdateRule(ctx context.Context, params notification.UpdateRuleInput) (*notification.Rule, error)

Constants

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

Types

type Config

type Config struct {
	FeatureConnector productcatalog.FeatureConnector

	Repository notification.Repository
	Webhook    webhook.Handler

	Logger *slog.Logger
}

type Service

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

func New

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

func (Service) Close

func (s Service) Close() 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) ([]productcatalog.Feature, error)

func (Service) ListRules

func (s Service) ListRules(ctx context.Context, params notification.ListRulesInput) (notification.ListRulesResult, 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)