Versions in this module Expand all Collapse all v0 v0.6.0 Oct 30, 2026 Changes in this version + var ErrOrgRequired = errors.New("organization is required") + type ChannelService struct + func NewChannelService(repo port.ChannelRepository) *ChannelService + func (s *ChannelService) Create(ctx context.Context, in CreateChannelInput) (*domain.Channel, error) + func (s *ChannelService) Delete(ctx context.Context, orgID, id string) error + func (s *ChannelService) Get(ctx context.Context, orgID, id string) (*domain.Channel, error) + func (s *ChannelService) List(ctx context.Context, orgID string) ([]*domain.Channel, error) + func (s *ChannelService) Update(ctx context.Context, orgID, id string, u domain.ChannelUpdate) (*domain.Channel, error) + type CreateChannelInput struct + Active *bool + Events []sharednotify.EventType + Name string + OrgID string + Secret string + Settings domain.Settings + Type domain.ChannelType + type Deliverer struct + func NewDeliverer(senders map[domain.ChannelType]port.Sender, deliveries port.DeliveryRepository) *Deliverer + func (d *Deliverer) Deliver(ctx context.Context, ch *domain.Channel, msg domain.Message) *domain.Delivery + type Dispatcher struct + func NewDispatcher(channels port.ChannelRepository, deliverer *Deliverer) *Dispatcher + func (d *Dispatcher) Publish(ctx context.Context, event sharednotify.Event) error + type ListDeliveries struct + func NewListDeliveries(deliveries port.DeliveryRepository) *ListDeliveries + func (l *ListDeliveries) Execute(ctx context.Context, orgID string, limit int) ([]*domain.Delivery, error) + type SendTest struct + func NewSendTest(channels port.ChannelRepository, deliverer *Deliverer) *SendTest + func (s *SendTest) Execute(ctx context.Context, orgID, id string) (*domain.Delivery, error)
Go to main page