server

Documentation

Index

• Variables
• func HealthHandler() *nethttp.ServeMux
• func NewGRPCServer(c *conf.Bootstrap, movieProvider *adaptor.MovieProvider) *grpc.Server
• func NewHTTPServer(c *conf.Bootstrap, movieProvider *adaptor.MovieProvider) *http.Server
• func NewWorker(c *conf.Bootstrap, job *Job) *worker.Worker
• type Job
  • func NewJob(c *conf.Bootstrap, i4kSyncTask *task.I4kSyncTask) *Job
  • func (j *Job) Start(ctx context.Context) error
  • func (j *Job) Stop(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(NewGRPCServer, NewHTTPServer, NewJob)

ProviderSet is server providers.

Functions

func HealthHandler

func HealthHandler() *nethttp.ServeMux

func NewGRPCServer

func NewGRPCServer(
	c *conf.Bootstrap,
	movieProvider *adaptor.MovieProvider,
) *grpc.Server

NewGRPCServer new a gRPC server.

func NewHTTPServer

func NewHTTPServer(
	c *conf.Bootstrap,
	movieProvider *adaptor.MovieProvider,
) *http.Server

NewHTTPServer new a HTTP server.

func NewWorker

func NewWorker(c *conf.Bootstrap, job *Job) *worker.Worker

Types

type Job

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

func NewJob

func NewJob(c *conf.Bootstrap, i4kSyncTask *task.I4kSyncTask) *Job

func (*Job) Start

func (j *Job) Start(ctx context.Context) error

func (*Job) Stop

func (j *Job) Stop(ctx context.Context) error