bind

Documentation

Index

• type HealthRPCServer
  • func NewHealthRPC() *HealthRPCServer
  • func (a HealthRPCServer) SetRoutes(srv *grpc.Server)
• type MediaEventConsumer
  • func NewMediaEventConsumer(svc usecase.MediaSAGAInteractor, logger log.Logger, cfg *config.Kernel) *MediaEventConsumer
  • func (c *MediaEventConsumer) SetBinders(s *eventbus.Server, ctx context.Context, service string) error
• type MediaHandler
  • func NewMediaHTTP(svc usecase.MediaInteractor, logger log.Logger, tracer stdopentracing.Tracer, ...) *MediaHandler
  • func (h *MediaHandler) Create() *httptransport.Server
  • func (h *MediaHandler) Delete() *httptransport.Server
  • func (h *MediaHandler) Get() *httptransport.Server
  • func (h *MediaHandler) HardDelete() *httptransport.Server
  • func (h *MediaHandler) List() *httptransport.Server
  • func (h *MediaHandler) Restore() *httptransport.Server
  • func (h *MediaHandler) SetRoutes(public, private, admin *mux.Router)
  • func (h *MediaHandler) Update() *httptransport.Server
• type MediaRPCServer
  • func NewMediaRPC(svc usecase.MediaInteractor, logger log.Logger, tracer stdopentracing.Tracer, ...) *MediaRPCServer
  • func (a MediaRPCServer) SetRoutes(srv *grpc.Server)

Types

type HealthRPCServer

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

func NewHealthRPC

func NewHealthRPC() *HealthRPCServer

func (HealthRPCServer) SetRoutes

func (a HealthRPCServer) SetRoutes(srv *grpc.Server)

type MediaEventConsumer

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

func NewMediaEventConsumer

func NewMediaEventConsumer(svc usecase.MediaSAGAInteractor, logger log.Logger, cfg *config.Kernel) *MediaEventConsumer

func (*MediaEventConsumer) SetBinders

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

type MediaHandler

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

func NewMediaHTTP

func NewMediaHTTP(svc usecase.MediaInteractor, logger log.Logger, tracer stdopentracing.Tracer, zipkinTracer *stdzipkin.Tracer) *MediaHandler

func (*MediaHandler) Create

func (h *MediaHandler) Create() *httptransport.Server

func (*MediaHandler) Delete

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

func (*MediaHandler) Get

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

func (*MediaHandler) HardDelete

func (h *MediaHandler) HardDelete() *httptransport.Server

func (*MediaHandler) List

func (h *MediaHandler) List() *httptransport.Server

func (*MediaHandler) Restore

func (h *MediaHandler) Restore() *httptransport.Server

func (*MediaHandler) SetRoutes

func (h *MediaHandler) SetRoutes(public, private, admin *mux.Router)

SetRoutes implement Handler interface for HTTP Proxy

func (*MediaHandler) Update

func (h *MediaHandler) Update() *httptransport.Server

type MediaRPCServer

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

func NewMediaRPC

func NewMediaRPC(svc usecase.MediaInteractor, logger log.Logger, tracer stdopentracing.Tracer, zipkinTracer *stdzipkin.Tracer) *MediaRPCServer

func (MediaRPCServer) SetRoutes

func (a MediaRPCServer) SetRoutes(srv *grpc.Server)