bind

Documentation

Index

• type BlobEventConsumer
  • func NewBlobEventConsumer(svc usecase.BlobSagaInteractor, logger log.Logger, cfg *config.Kernel) *BlobEventConsumer
  • func (c *BlobEventConsumer) SetBinders(s *eventbus.Server, ctx context.Context, service string) error
• type BlobHandler
  • func NewBlobHandler(svc usecase.BlobInteractor, logger log.Logger, tracer stdopentracing.Tracer, ...) *BlobHandler
  • func (h *BlobHandler) Delete() *httptransport.Server
  • func (h *BlobHandler) Get() *httptransport.Server
  • func (h *BlobHandler) SetRoutes(public, private, _ *mux.Router)
  • func (h *BlobHandler) Store() *httptransport.Server

Types

type BlobEventConsumer

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

func NewBlobEventConsumer

func NewBlobEventConsumer(svc usecase.BlobSagaInteractor, logger log.Logger, cfg *config.Kernel) *BlobEventConsumer

func (*BlobEventConsumer) SetBinders

func (c *BlobEventConsumer) SetBinders(s *eventbus.Server, ctx context.Context, service string) error

type BlobHandler

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

func NewBlobHandler

func NewBlobHandler(svc usecase.BlobInteractor, logger log.Logger, tracer stdopentracing.Tracer, zipkinTracer *stdzipkin.Tracer) *BlobHandler

func (*BlobHandler) Delete

func (h *BlobHandler) Delete() *httptransport.Server

func (*BlobHandler) Get

func (h *BlobHandler) Get() *httptransport.Server

func (*BlobHandler) SetRoutes

func (h *BlobHandler) SetRoutes(public, private, _ *mux.Router)

func (*BlobHandler) Store

func (h *BlobHandler) Store() *httptransport.Server