relay

Documentation

Index

• type Relay
  • func NewRelay(cfg *conf.Config, cmgr cmgr.Cmgr) (*Relay, error)
  • func (r *Relay) ListenAndServe(ctx context.Context) error
  • func (r *Relay) Stop() error
  • func (r *Relay) UniqueID() string
• type Server
  • func NewServer(cfg *config.Config) (*Server, error)
  • func (r *Server) HealthCheck(ctx context.Context, relayID string) (int64, error)
  • func (s *Server) Reload(force bool) error
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop() error
  • func (s *Server) TriggerReload()
  • func (s *Server) TriggerReloadBySignal(ctx context.Context)
  • func (s *Server) WatchAndReload(ctx context.Context)

Types

type Relay

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

func NewRelay

func NewRelay(cfg *conf.Config, cmgr cmgr.Cmgr) (*Relay, error)

func (*Relay) ListenAndServe

func (r *Relay) ListenAndServe(ctx context.Context) error

func (*Relay) Stop

func (r *Relay) Stop() error

func (*Relay) UniqueID

func (r *Relay) UniqueID() string

type Server

type Server struct {
	Cmgr cmgr.Cmgr
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg *config.Config) (*Server, error)

func (*Server) HealthCheck

func (r *Server) HealthCheck(ctx context.Context, relayID string) (int64, error)

func (*Server) Reload

func (s *Server) Reload(force bool) error

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop() error

func (*Server) TriggerReload

func (s *Server) TriggerReload()

func (*Server) TriggerReloadBySignal

func (s *Server) TriggerReloadBySignal(ctx context.Context)

func (*Server) WatchAndReload

func (s *Server) WatchAndReload(ctx context.Context)