relay

Dec 8, 2023

Changes in this version

type RemoteClientCfg

+ SessionID string

Aug 11, 2023

Changes in this version

type RemoteClientCfg

+ TenantID string

Apr 26, 2023

Changes in this version

type RemoteClientCfg

+ BasicAuthPassword string

+ BasicAuthUser string

+ HTTPHeadersJSON string

+ ScopeOrgID string

Oct 28, 2022

Changes in this version

type RemoteClientCfg

+ MaxIdleConnsPerHost int

type RemoteQueue

+ func (r *RemoteQueue) Flush()

Jul 4, 2022

Changes in this version

+ var ErrMakingRequest = errors.New("failed to make request")

+ var ErrNotOkResponse = errors.New("response not ok")

+ type Controller struct

+ func NewController(log *logrus.Entry, queue *RemoteQueue) *Controller

+ func (c *Controller) RelayRequest(w http.ResponseWriter, r *http.Request)

+ type Orchestrator struct

+ func NewOrchestrator(log *logrus.Entry, queue *RemoteQueue, server *Server, ...) *Orchestrator

+ func (o *Orchestrator) Shutdown() error

+ func (o *Orchestrator) Start() error

+ type Relayer interface

+ Send func(req *http.Request) error

+ type RemoteClient struct

+ func NewRemoteClient(log *logrus.Entry, config *RemoteClientCfg) *RemoteClient

+ func (r *RemoteClient) Send(req *http.Request) error

+ type RemoteClientCfg struct

+ Address string

+ AuthToken string

+ Timeout time.Duration

+ type RemoteQueue struct

+ func NewRemoteQueue(log *logrus.Entry, config *RemoteQueueCfg, relayer Relayer) *RemoteQueue

+ func (r *RemoteQueue) Send(req *http.Request) error

+ func (r *RemoteQueue) Start() error

+ func (r *RemoteQueue) Stop(_ context.Context) error

+ type RemoteQueueCfg struct

+ NumWorkers int

+ type Server struct

+ func NewServer(logger *logrus.Entry, config *ServerCfg, handlerFunc http.HandlerFunc) *Server

+ func (s *Server) Start() error

+ func (s *Server) Stop(ctx context.Context) error

+ type ServerCfg struct

+ ServerAddress string

+ type StartStopper interface

+ Start func() error

+ Stop func(context.Context) error