service

Documentation

Index

• type Service
  • func New(log logr.Logger, store products.Store) *Service
  • func (s *Service) RegisterEventHandlers(app *fiber.App)
  • func (s *Service) RegisterService(app *fiber.App)
  • func (s *Service) RegisterTopicEventHandlers(register dapr.RegisterEventHandler)
  • func (s *Service) RegisterTopicEventHandlersSDK(service common.Service) error
  • func (s *Service) SaveGRPC(ctx context.Context, in *pb.TopicEventRequest) (*pb.TopicEventResponse, error)
  • func (s *Service) SaveHTTP(c *fiber.Ctx) error
  • func (s *Service) SaveSDK(ctx context.Context, e *common.TopicEvent) (retry bool, err error)
  • func (s *Service) Subscriptions() []dapr.Subscription

Types

type Service

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

func New

func New(log logr.Logger, store products.Store) *Service

func (*Service) RegisterEventHandlers

func (s *Service) RegisterEventHandlers(app *fiber.App)

func (*Service) RegisterService

func (s *Service) RegisterService(app *fiber.App)

func (*Service) RegisterTopicEventHandlers

func (s *Service) RegisterTopicEventHandlers(register dapr.RegisterEventHandler)

func (*Service) RegisterTopicEventHandlersSDK

func (s *Service) RegisterTopicEventHandlersSDK(service common.Service) error

func (*Service) SaveGRPC

func (s *Service) SaveGRPC(ctx context.Context, in *pb.TopicEventRequest) (*pb.TopicEventResponse, error)

func (*Service) SaveHTTP

func (s *Service) SaveHTTP(c *fiber.Ctx) error

func (*Service) SaveSDK

func (s *Service) SaveSDK(ctx context.Context, e *common.TopicEvent) (retry bool, err error)

func (*Service) Subscriptions

func (s *Service) Subscriptions() []dapr.Subscription