eventsource

type Intermediate ¶

type Intermediate struct {
	*connector.Connector
	ToDo
}

Intermediate extends and customizes the generic base connector.

func NewIntermediate(impl ToDo) *Intermediate

type Mock ¶

type Mock struct {
	*Intermediate
	// contains filtered or unexported fields
}

Mock is a mockable version of the microservice, allowing functions, event sinks and web handlers to be mocked.

func NewMock() *Mock

func (svc *Mock) MockRegister(handler func(ctx context.Context, email string) (allowed bool, err error)) *Mock

func (svc *Mock) OnShutdown(ctx context.Context) (err error)

func (svc *Mock) OnStartup(ctx context.Context) (err error)

func (svc *Mock) Register(ctx context.Context, email string) (allowed bool, err error)

type Service ¶

type Service struct {
	*Intermediate // IMPORTANT: Do not remove
}

Service implements the eventsource.example microservice.

The event source microservice fires events that are caught by the event sink microservice.

func NewService() *Service

func (svc *Service) Init(initializer func(svc *Service) (err error)) *Service

func (svc *Service) OnShutdown(ctx context.Context) (err error)

func (svc *Service) OnStartup(ctx context.Context) (err error)

func (svc *Service) Register(ctx context.Context, email string) (allowed bool, err error)

type ToDo ¶

type ToDo interface {
	OnStartup(ctx context.Context) (err error)
	OnShutdown(ctx context.Context) (err error)
	Register(ctx context.Context, email string) (allowed bool, err error) // MARKER: Register
}

ToDo is implemented by the service or mock. The intermediate delegates handling to this interface.