process

Documentation

Index

• func NewProcess(ctx context.Context, cfg processconfig.Config, tcfg teleconfig.FileConfig) (process.GravityProcess, error)
• type Handlers
• type Process
  • func New(ctx context.Context, cfg processconfig.Config, tcfg teleconfig.FileConfig) (*Process, error)
  • func (p *Process) Init() error
  • func (p *Process) Serve() error
  • func (p *Process) Start() (err error)

Functions

func NewProcess

func NewProcess(ctx context.Context, cfg processconfig.Config, tcfg teleconfig.FileConfig) (process.GravityProcess, error)

NewProcess creates a new instance of enterprise gravity API server

Satisfies process.NewGravityProcess function type.

Types

type Handlers

type Handlers struct {
	// Handlers is the open-source handlers
	*process.Handlers
	// Operator extends the open-source ops service handler
	Operator *handler.WebHandler
	// WebAPI extends the open-source web API handler
	WebAPI *webapi.Handler
}

Handlers extends open-source web handlers with enterprise handlers

type Process

type Process struct {
	// Process is the underlying open-source version of the process
	*process.Process
	// contains filtered or unexported fields
}

Process extends open-source gravity process with enterprise specific features

func New

func New(ctx context.Context, cfg processconfig.Config, tcfg teleconfig.FileConfig) (*Process, error)

New returns a new uninitialized instance of an enterprise process

func (*Process) Init

func (p *Process) Init() error

Init initializes the enterprise gravity process, it can then be started using Start

func (*Process) Serve

func (p *Process) Serve() error

Serve starts serving all process web services

func (*Process) Start

func (p *Process) Start() (err error)

Start starts all process services