jobservice

Documentation

Index

• Variables
• func ProcessSubs(subRequests <-chan SubRequest, sqlJobRepo repository.SQLJobService)
• func RectifyConfig(config *configuration.JobServiceConfiguration)
• type App
  • func New() *App
  • func (a *App) StartUp(ctx context.Context, config *configuration.JobServiceConfiguration) error
• type SubRequest

Variables

var DefaultConfiguration = &configuration.JobServiceConfiguration{
	GrpcPool: grpcconfig.GrpcPoolConfig{
		InitialConnections: 5,
		Capacity:           5,
	},
	SubscriberPoolSize: 30,
}

Functions

func ProcessSubs

func ProcessSubs(subRequests <-chan SubRequest, sqlJobRepo repository.SQLJobService)

ProcessSubs continually reads from the channel of incoming jobset subscription requests and subscribes as they are received

func RectifyConfig

func RectifyConfig(config *configuration.JobServiceConfiguration)

Mutates config where possible to correct mis-configurations.

Types

type App

type App struct {
	// Configuration for jobService
	Config *configuration.JobServiceConfiguration
}

func New

func New() *App

func (*App) StartUp

func (a *App) StartUp(ctx context.Context, config *configuration.JobServiceConfiguration) error

type SubRequest

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