coordinator

Documentation

Index

• Constants
• func ReadParam(ctx *vk.Ctx, name string) string
• type Coordinator
  • func New(syncer *syncer.Syncer, options *options.Options) *Coordinator
  • func (c *Coordinator) SetupHandlers() (*vk.Router, error)
  • func (c *Coordinator) SetupWorkflows(router *vk.Router) error
  • func (c *Coordinator) Shutdown()
  • func (c *Coordinator) Start() error
• type MetricsResponse
• type Values

Constants

const (
	E2CoreMetricsURI = "/meta/metrics"
	E2CoreHealthURI  = "/health"
)

Functions

func ReadParam

func ReadParam(ctx *vk.Ctx, name string) string

Types

type Coordinator

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

Coordinator is a type that is responsible for converting the directive into usable Vektor handles by coordinating Reactr jobs and meshing when needed.

func New

func New(syncer *syncer.Syncer, options *options.Options) *Coordinator

New creates a coordinator.

func (*Coordinator) SetupHandlers

func (c *Coordinator) SetupHandlers() (*vk.Router, error)

SetupHandlers configures all of the app's handlers and generates a Vektor Router for the app.

func (*Coordinator) SetupWorkflows

func (c *Coordinator) SetupWorkflows(router *vk.Router) error

TODO: Workflows are not fully implemented, need to add scheduled execution

func (*Coordinator) Shutdown

func (c *Coordinator) Shutdown()

func (*Coordinator) Start

func (c *Coordinator) Start() error

Start allows the Coordinator to bootstrap.

type MetricsResponse

type MetricsResponse struct {
	Scheduler scheduler.ScalerMetrics `json:"scheduler"`
}

type Values

type Values struct {
	TraceID   string
	Now       time.Time
	RequestID string
}

Values represent state for each request.