v1

Documentation

Index

• type DispatcherService
  • func NewDispatcherService(fs ...DispatcherServiceOpt) (DispatcherService, error)
• type DispatcherServiceImpl
  • func (d *DispatcherServiceImpl) DeliverDurableEventLogEntryCompletion(taskExternalId uuid.UUID, invocationCount int32, branchId, nodeId int64, ...) error
  • func (d *DispatcherServiceImpl) DurableTask(server contracts.V1Dispatcher_DurableTaskServer) error
  • func (d *DispatcherServiceImpl) ListenForDurableEvent(server contracts.V1Dispatcher_ListenForDurableEventServer) error
  • func (d *DispatcherServiceImpl) RegisterDurableEvent(ctx context.Context, req *contracts.RegisterDurableEventRequest) (*contracts.RegisterDurableEventResponse, error)
• type DispatcherServiceOpt
  • func WithAnalytics(a analytics.Analytics) DispatcherServiceOpt
  • func WithDispatcherId(id uuid.UUID) DispatcherServiceOpt
  • func WithLogger(l *zerolog.Logger) DispatcherServiceOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) DispatcherServiceOpt
  • func WithRepository(r v1.Repository) DispatcherServiceOpt
  • func WithValidator(v validator.Validator) DispatcherServiceOpt
• type DispatcherServiceOpts

Types

type DispatcherService

type DispatcherService interface {
	contracts.V1DispatcherServer
	DeliverDurableEventLogEntryCompletion(taskExternalId uuid.UUID, invocationCount int32, branchId, nodeId int64, payload []byte) error
}

func NewDispatcherService

func NewDispatcherService(fs ...DispatcherServiceOpt) (DispatcherService, error)

type DispatcherServiceImpl

type DispatcherServiceImpl struct {
	contracts.UnimplementedV1DispatcherServer
	// contains filtered or unexported fields
}

func (*DispatcherServiceImpl) DeliverDurableEventLogEntryCompletion

func (d *DispatcherServiceImpl) DeliverDurableEventLogEntryCompletion(taskExternalId uuid.UUID, invocationCount int32, branchId, nodeId int64, payload []byte) error

func (*DispatcherServiceImpl) DurableTask

func (d *DispatcherServiceImpl) DurableTask(server contracts.V1Dispatcher_DurableTaskServer) error

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 WithAnalytics

func WithAnalytics(a analytics.Analytics) DispatcherServiceOpt

func WithDispatcherId

func WithDispatcherId(id uuid.UUID) DispatcherServiceOpt

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
}