controller

Documentation

Index

• type Controller
  • func New(ctx *cli.Context) (*Controller, error)
  • func NewWithDependencies(listener net.Listener, recorder metrics.MetricsRecorder, backend state.State) *Controller
  • func (c *Controller) Addr() string
  • func (c *Controller) Port() int
  • func (c *Controller) Serve() error
  • func (c *Controller) Shutdown(ctx context.Context) error
• type TaskStatus

Types

type Controller

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

func New

func New(ctx *cli.Context) (*Controller, error)

func NewWithDependencies

func NewWithDependencies(listener net.Listener, recorder metrics.MetricsRecorder, backend state.State) *Controller

func (*Controller) Addr

func (c *Controller) Addr() string

func (*Controller) Port

func (c *Controller) Port() int

func (*Controller) Serve

func (c *Controller) Serve() error

Serve starts the server and blocks until the server is closed, either explicitly via Shutdown, or due to a fault condition. It propagates the non-nil err return value from http.Serve.

func (*Controller) Shutdown

func (c *Controller) Shutdown(ctx context.Context) error

type TaskStatus

type TaskStatus struct {
	UUID    string      `json:"uuid"`
	Type    string      `json:"type"`
	Payload interface{} `json:"payload"`
}