Documentation
¶
Index ¶
- func ValidatedGatewaySpec(tomlString string) (job.Job, error)
- type ConnectionManager
- type Delegate
- func (d *Delegate) AfterJobCreated(spec job.Job)
- func (d *Delegate) BeforeJobCreated(spec job.Job)
- func (d *Delegate) BeforeJobDeleted(spec job.Job)
- func (d *Delegate) JobType() job.Type
- func (d *Delegate) OnDeleteJob(spec job.Job, q pg.Queryer) error
- func (d *Delegate) ServicesForSpec(ctx context.Context, spec job.Job) (services []job.ServiceCtx, err error)
- type Gateway
- type HandlerFactory
- type HandlerType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConnectionManager ¶
type ConnectionManager interface {
job.ServiceCtx
network.ConnectionAcceptor
DONConnectionManager(donId string) *donConnectionManager
GetPort() int
}
ConnectionManager holds all connections between Gateway and Nodes.
func NewConnectionManager ¶
func NewConnectionManager(gwConfig *config.GatewayConfig, clock clockwork.Clock, lggr logger.Logger) (ConnectionManager, error)
type Delegate ¶ added in v2.3.0
type Delegate struct {
// contains filtered or unexported fields
}
func NewDelegate ¶ added in v2.3.0
func (*Delegate) AfterJobCreated ¶ added in v2.3.0
func (*Delegate) BeforeJobCreated ¶ added in v2.3.0
func (*Delegate) BeforeJobDeleted ¶ added in v2.3.0
func (*Delegate) OnDeleteJob ¶ added in v2.3.0
func (*Delegate) ServicesForSpec ¶ added in v2.3.0
func (d *Delegate) ServicesForSpec(ctx context.Context, spec job.Job) (services []job.ServiceCtx, err error)
ServicesForSpec returns the scheduler to be used for running observer jobs
type Gateway ¶
type Gateway interface {
job.ServiceCtx
gw_net.HTTPRequestHandler
GetUserPort() int
GetNodePort() int
}
func NewGateway ¶
func NewGatewayFromConfig ¶
func NewGatewayFromConfig(config *config.GatewayConfig, handlerFactory HandlerFactory, lggr logger.Logger) (Gateway, error)
type HandlerFactory ¶ added in v2.3.0
type HandlerFactory interface {
NewHandler(handlerType HandlerType, handlerConfig json.RawMessage, donConfig *config.DONConfig, don handlers.DON) (handlers.Handler, error)
}
func NewHandlerFactory ¶ added in v2.3.0
func NewHandlerFactory(legacyChains legacyevm.LegacyChainContainer, db *sqlx.DB, cfg pg.QConfig, lggr logger.Logger) HandlerFactory
type HandlerType ¶
type HandlerType = string
const ( FunctionsHandlerType HandlerType = "functions" DummyHandlerType HandlerType = "dummy" )
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.