Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DispatcherService ¶
type DispatcherService interface {
contracts.V1DispatcherServer
}
func NewDispatcherService ¶
func NewDispatcherService(fs ...DispatcherServiceOpt) (DispatcherService, error)
type DispatcherServiceImpl ¶
type DispatcherServiceImpl struct {
contracts.UnimplementedV1DispatcherServer
// contains filtered or unexported fields
}
func (*DispatcherServiceImpl) ListenForDurableEvent ¶
func (d *DispatcherServiceImpl) ListenForDurableEvent(server contracts.V1Dispatcher_ListenForDurableEventServer) error
func (*DispatcherServiceImpl) RegisterDurableEvent ¶
func (d *DispatcherServiceImpl) RegisterDurableEvent(ctx context.Context, req *contracts.RegisterDurableEventRequest) (*contracts.RegisterDurableEventResponse, error)
type DispatcherServiceOpt ¶
type DispatcherServiceOpt func(*DispatcherServiceOpts)
func WithLogger ¶
func WithLogger(l *zerolog.Logger) DispatcherServiceOpt
func WithMessageQueue ¶
func WithMessageQueue(mq msgqueue.MessageQueue) DispatcherServiceOpt
func WithRepository ¶
func WithRepository(r v1.Repository) DispatcherServiceOpt
func WithValidator ¶
func WithValidator(v validator.Validator) DispatcherServiceOpt
type DispatcherServiceOpts ¶
type DispatcherServiceOpts struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.