server

Documentation

Index

• Variables
• func NewGRPCServer(c *conf.Server, pingService *service.PingService, logger log.Logger) *grpc.Server
• func NewHTTPServer(c *conf.Server, pingService *service.PingService, ...) *http.Server
• type EventHandler
• type Watch
  • func NewWatch(c *conf.Interflow, d *data.Data, loadService *service.LoadService, ...) (*Watch, error)
  • func (w *Watch) Start(_ context.Context) error
  • func (w *Watch) Stop(_ context.Context) error

Variables

var ProviderSetServer = wire.NewSet(NewGRPCServer, NewHTTPServer, NewWatch)

ProviderSetServer is server providers.

Functions

func NewGRPCServer

func NewGRPCServer(c *conf.Server, pingService *service.PingService, logger log.Logger) *grpc.Server

NewGRPCServer new a gRPC server.

func NewHTTPServer

func NewHTTPServer(
	c *conf.Server,
	pingService *service.PingService,
	hookService *service.HookService,
	interflowService *service.HookInterflowService,
	logger log.Logger,
) *http.Server

NewHTTPServer new an HTTP server.

Types

type EventHandler

type EventHandler = interflow.Callback

type Watch

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

func NewWatch

func NewWatch(
	c *conf.Interflow,
	d *data.Data,
	loadService *service.LoadService,
	logger log.Logger,
) (*Watch, error)

func (*Watch) Start

func (w *Watch) Start(_ context.Context) error

func (*Watch) Stop

func (w *Watch) Stop(_ context.Context) error