gateway

Documentation

Index

• Constants
• type DataSourceObserver
• type DataSourceSubject
• type DatasourcePollerConfig
• type DatasourcePollerPoller
  • func NewDatasource(serviceConfig []ServiceConfig, httpClient *http.Client) *DatasourcePollerPoller
  • func NewDatasourcePoller(httpClient *http.Client, config DatasourcePollerConfig) *DatasourcePollerPoller
  • func (d *DatasourcePollerPoller) Register(updateDatasourceObserver DataSourceObserver)
  • func (d *DatasourcePollerPoller) Run(ctx context.Context)
• type GQLErr
  • func (g GQLErr) Error() string
• type Gateway
  • func Handler(logger log.Logger, datasourcePoller *DatasourcePollerPoller, ...) *Gateway
  • func NewGateway(gqlHandlerFactory HandlerFactory, httpClient *http.Client, logger log.Logger) *Gateway
  • func (g *Gateway) Ready()
  • func (g *Gateway) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (g *Gateway) UpdateDataSources(newDataSourcesConfig []graphql.DataSourceConfiguration)
• type HandlerFactory
• type HandlerFactoryFn
  • func (h HandlerFactoryFn) Make(schema *graphql.Schema, engine *graphql.ExecutionEngineV2) http.Handler
• type ServiceConfig

Constants

const ServiceDefinitionQuery = `` /* 150-byte string literal not displayed */

Types

type DataSourceObserver

type DataSourceObserver interface {
	UpdateDataSources(newDataSourcesConfig []graphql.DataSourceConfiguration)
}

type DataSourceSubject

type DataSourceSubject interface {
	Register(observer DataSourceObserver)
}

type DatasourcePollerConfig

type DatasourcePollerConfig struct {
	Services        []ServiceConfig
	PollingInterval time.Duration
}

type DatasourcePollerPoller

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

func NewDatasource

func NewDatasource(serviceConfig []ServiceConfig, httpClient *http.Client) *DatasourcePollerPoller

func NewDatasourcePoller

func NewDatasourcePoller(
	httpClient *http.Client,
	config DatasourcePollerConfig,
) *DatasourcePollerPoller

func (*DatasourcePollerPoller) Register

func (d *DatasourcePollerPoller) Register(updateDatasourceObserver DataSourceObserver)

func (*DatasourcePollerPoller) Run

func (d *DatasourcePollerPoller) Run(ctx context.Context)

type GQLErr

type GQLErr []struct {
	Message string `json:"message"`
}

func (GQLErr) Error

func (g GQLErr) Error() string

type Gateway

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

func Handler

func Handler(
	logger log.Logger,
	datasourcePoller *DatasourcePollerPoller,
	httpClient *http.Client,
) *Gateway

func NewGateway

func NewGateway(
	gqlHandlerFactory HandlerFactory,
	httpClient *http.Client,
	logger log.Logger,
) *Gateway

func (*Gateway) Ready

func (g *Gateway) Ready()

func (*Gateway) ServeHTTP

func (g *Gateway) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Gateway) UpdateDataSources

func (g *Gateway) UpdateDataSources(newDataSourcesConfig []graphql.DataSourceConfiguration)

Error handling is not finished.

type HandlerFactory

type HandlerFactory interface {
	Make(schema *graphql.Schema, engine *graphql.ExecutionEngineV2) http.Handler
}

type HandlerFactoryFn

type HandlerFactoryFn func(schema *graphql.Schema, engine *graphql.ExecutionEngineV2) http.Handler

func (HandlerFactoryFn) Make

func (h HandlerFactoryFn) Make(schema *graphql.Schema, engine *graphql.ExecutionEngineV2) http.Handler

type ServiceConfig

type ServiceConfig struct {
	Name string
	URL  string
	WS   string
}