service

Documentation

Index

• type CircleSubscriptionHandler
  • func NewCircleSubscriptionHandler(repo repository.Repository, cricleAPI circlePb.CircleAPIClient) CircleSubscriptionHandler
  • func (h CircleSubscriptionHandler) HandleCircleEventSubscription(ctx context.Context, e *event.Event) error
  • func (h CircleSubscriptionHandler) HandleDiscordWebhookConfigured(ctx context.Context, circleId string) error
  • func (h CircleSubscriptionHandler) HandleDiscordWebhookRevoked(ctx context.Context, circleId string) error
• type ContentSubscriptionHandler
  • func NewContentSubscriptionHandler(repo repository.Repository, contentAPIClient contentPb.ContentAPIClient, ...) ContentSubscriptionHandler
  • func (h ContentSubscriptionHandler) HandleContentEventSubscription(ctx context.Context, e *event.Event) error
  • func (h ContentSubscriptionHandler) HandleNewPostEvent(ctx context.Context, postID string) error
• type GetDummyHandler
  • func NewGetDummyHandler(repo repository.Repository, publisher pub.EventBusPublisher) GetDummyHandler
  • func (h GetDummyHandler) GetDummy(ctx context.Context, dummyID string) (*model.Dummy, error)
• type Service
  • func New(repo repository.Repository, eventPublisher pub.EventBusPublisher, ...) Service
• type SubscriptionHandlers

Types

type CircleSubscriptionHandler

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

func NewCircleSubscriptionHandler

func NewCircleSubscriptionHandler(repo repository.Repository,
	cricleAPI circlePb.CircleAPIClient,
) CircleSubscriptionHandler

func (CircleSubscriptionHandler) HandleCircleEventSubscription

func (h CircleSubscriptionHandler) HandleCircleEventSubscription(ctx context.Context, e *event.Event) error

func (CircleSubscriptionHandler) HandleDiscordWebhookConfigured

func (h CircleSubscriptionHandler) HandleDiscordWebhookConfigured(ctx context.Context, circleId string) error

func (CircleSubscriptionHandler) HandleDiscordWebhookRevoked

func (h CircleSubscriptionHandler) HandleDiscordWebhookRevoked(ctx context.Context, circleId string) error

type ContentSubscriptionHandler

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

func NewContentSubscriptionHandler

func NewContentSubscriptionHandler(
	repo repository.Repository, contentAPIClient contentPb.ContentAPIClient,
	profileAPIClient profilePb.ProfileAPIClient, completer url.Completer,
) ContentSubscriptionHandler

func (ContentSubscriptionHandler) HandleContentEventSubscription

func (h ContentSubscriptionHandler) HandleContentEventSubscription(ctx context.Context, e *event.Event) error

func (ContentSubscriptionHandler) HandleNewPostEvent

func (h ContentSubscriptionHandler) HandleNewPostEvent(ctx context.Context, postID string) error

type GetDummyHandler

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

func NewGetDummyHandler

func NewGetDummyHandler(repo repository.Repository, publisher pub.EventBusPublisher) GetDummyHandler

func (GetDummyHandler) GetDummy

func (h GetDummyHandler) GetDummy(ctx context.Context, dummyID string) (*model.Dummy, error)

type Service

type Service struct {
	GetDummyHandler
	SubscriptionHandlers
}

func New

func New(
	repo repository.Repository,
	eventPublisher pub.EventBusPublisher,

	contentAPI contentPb.ContentAPIClient,
	circleAPI circlePb.CircleAPIClient,
	profileAPI profilePb.ProfileAPIClient,

	completer url.Completer,
) Service

type SubscriptionHandlers

type SubscriptionHandlers struct {
	ContentSubscriptionHandler
	CircleSubscriptionHandler
}