server

Documentation

Index

• type CronTask
• type Event
• type GrpcHandler
• type HttpHandler
• type Server
  • func NewServer(ctx context.Context, logger *slog.Logger, tracer trace.Tracer, ...) *Server
  • func (s *Server) AddDiscovery(discovery discovery.Discovery)
  • func (s *Server) Cron(tasks []CronTask)
  • func (s *Server) Grpc(cfg *config.Grpc, handlers ...GrpcHandler)
  • func (s *Server) Http(cfg *config.Http, cfgRpc *config.Grpc, handlers ...HttpHandler)
  • func (s *Server) Run() error

Types

type CronTask

type CronTask struct {
	Name string
	Cron string
	Fn   func(ctx context.Context) error
}

type Event

type Event struct {
	ServiceStart func() error
	ServiceStop  func() error
	WorkerStart  func() error
	WorkerStop   func() error
}

type GrpcHandler

type GrpcHandler func(*grpc.Server)

type HttpHandler

type HttpHandler func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error

type Server

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

func NewServer

func NewServer(ctx context.Context, logger *slog.Logger, tracer trace.Tracer, meter metric.Meter) *Server

func (*Server) AddDiscovery

func (s *Server) AddDiscovery(discovery discovery.Discovery)

func (*Server) Cron

func (s *Server) Cron(tasks []CronTask)

func (*Server) Grpc

func (s *Server) Grpc(cfg *config.Grpc, handlers ...GrpcHandler)

func (*Server) Http

func (s *Server) Http(cfg *config.Http, cfgRpc *config.Grpc, handlers ...HttpHandler)

func (*Server) Run

func (s *Server) Run() error