producer

Documentation

Index

• func MakeGenerateEventEndpoint(svc Service) endpoint.Endpoint
• func Middleware(producer endpoint.Endpoint) endpoint.Middleware
• func NewHTTPHandler(endpoints Endpoints) http.Handler
• func NewKafkaProducer(handler kafka.Handler, topic string) *transport.Producer
• type Endpoints
• type GenerateEventRequest
• type GenerateEventResponse
• type GeneratorService
  • func NewGeneratorService(logger log.Logger) (*GeneratorService, error)
  • func (svc *GeneratorService) Generate(_ context.Context) (*domain.Event, error)
• type ProduceEventRequest
• type ProduceEventResponse
• type Service

Functions

func MakeGenerateEventEndpoint

func MakeGenerateEventEndpoint(svc Service) endpoint.Endpoint

func Middleware

func Middleware(producer endpoint.Endpoint) endpoint.Middleware

func NewHTTPHandler

func NewHTTPHandler(endpoints Endpoints) http.Handler

func NewKafkaProducer

func NewKafkaProducer(handler kafka.Handler, topic string) *transport.Producer

Types

type Endpoints

type Endpoints struct {
	GenerateEvent endpoint.Endpoint
}

type GenerateEventRequest

type GenerateEventRequest struct {
}

type GenerateEventResponse

type GenerateEventResponse struct {
	Result *domain.Event
}

type GeneratorService

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

func NewGeneratorService

func NewGeneratorService(logger log.Logger) (*GeneratorService, error)

func (*GeneratorService) Generate

func (svc *GeneratorService) Generate(_ context.Context) (*domain.Event, error)

type ProduceEventRequest

type ProduceEventRequest struct {
	Payload *domain.Event
}

type ProduceEventResponse

type ProduceEventResponse struct {
}

type Service

type Service interface {
	Generate(ctx context.Context) (*domain.Event, error)
}