server

Documentation

Index

• Variables
• type IntegratorServer
  • func NewIntegratorServer(conf *conf.ServerConf, integrateService *service.IntegrateService, ...) *IntegratorServer
  • func (s *IntegratorServer) Init() error
  • func (s *IntegratorServer) Run(ctx context.Context, cleanUp func()) error
  • func (s *IntegratorServer) Stop() error

Variables

var ProviderSet = wire.NewSet(NewIntegratorServer)

Types

type IntegratorServer

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

func NewIntegratorServer

func NewIntegratorServer(
	conf *conf.ServerConf,
	integrateService *service.IntegrateService,
	registrar registry.Registrar,
) *IntegratorServer

NewIntegratorServer create integrator server

func (*IntegratorServer) Init

func (s *IntegratorServer) Init() error

func (*IntegratorServer) Run

func (s *IntegratorServer) Run(ctx context.Context, cleanUp func()) error

func (*IntegratorServer) Stop

func (s *IntegratorServer) Stop() error