link_cqrs

Documentation

Index

• type Service
  • func New(logger logger.Logger, cqsStore *cqs.Store, queryStore *query.Store) (*Service, error)
  • func (s *Service) EventHandlers()
  • func (s *Service) Get(ctx context.Context, hash string) (*domain.LinkView, error)
  • func (s *Service) List(ctx context.Context, filter *query.Filter) (*domain.LinksView, error)
  • func (s *Service) Notify(ctx context.Context, event uint32, payload interface{}) notify.Response

Types

type Service

type Service struct {
	// Observer interface for subscribe on system event
	notify.Subscriber // Observer interface for subscribe on system event
	// contains filtered or unexported fields
}

func New

func New(logger logger.Logger, cqsStore *cqs.Store, queryStore *query.Store) (*Service, error)

func (*Service) EventHandlers

func (s *Service) EventHandlers()

func (*Service) Get

func (s *Service) Get(ctx context.Context, hash string) (*domain.LinkView, error)

func (*Service) List

func (s *Service) List(ctx context.Context, filter *query.Filter) (*domain.LinksView, error)

func (*Service) Notify

func (s *Service) Notify(ctx context.Context, event uint32, payload interface{}) notify.Response