components

Documentation

Index

• type Application
• type Backend
• type Bus
• type Components
  • func New() *Components
  • func (cs *Components) Add(c components.Component)
  • func (cs *Components) Application() components.Application
  • func (cs *Components) Bus() components.Bus
  • func (cs *Components) Config() components.Config
  • func (cs *Components) Crypto() components.Crypto
  • func (cs *Components) Leader() components.Leader
  • func (cs *Components) Logger() logger.Logger
  • func (cs *Components) Model() components.Model
  • func (cs *Components) Router() components.Router
• type Config
• type Crypto
• type Leader
• type Manager
• type Metrics
• type Model
• type Router
• type Scheduler
• type Server
• type Workers

Types

type Application

type Application interface {
	components.Application
}

Application AFAIRE.

type Backend

type Backend interface {
	AcquireLock(name, owner string, duration time.Duration) (bool, error)
	ReleaseLock(name, owner string) error
	InsertJob(job *jw.Job) (bool, error)
	NextJob() (*jw.Job, error)
	UpdateJob(job *jw.Job) error
	Workflow(id string, mustExist bool) (*jw.Workflow, error)
	InsertWorkflow(wf *jw.Workflow, job *jw.Job) error
	UpdateWorkflow(wf *jw.Workflow) error
	Clean() (int, int, error)
}

Backend AFAIRE.

type Bus

type Bus interface {
	components.Bus
}

Bus AFAIRE.

type Components

type Components struct {
	CApplication Application
	CBackend     Backend
	CBus         Bus
	CConfig      Config
	CCrypto      Crypto
	CLeader      Leader
	CLogger      logger.Logger
	CManager     Manager
	CMetrics     Metrics
	CModel       Model
	CRouter      Router
	CScheduler   Scheduler
	CServer      Server
	CWorkers     Workers
	// contains filtered or unexported fields
}

Components AFAIRE.

func New

func New() *Components

New AFAIRE.

func (*Components) Add

func (cs *Components) Add(c components.Component)

Add AFAIRE.

func (*Components) Application

func (cs *Components) Application() components.Application

Application AFAIRE.

func (*Components) Bus

func (cs *Components) Bus() components.Bus

Bus AFAIRE.

func (*Components) Config

func (cs *Components) Config() components.Config

Config AFAIRE.

func (*Components) Crypto

func (cs *Components) Crypto() components.Crypto

Crypto AFAIRE.

func (*Components) Leader

func (cs *Components) Leader() components.Leader

Leader AFAIRE.

func (*Components) Logger

func (cs *Components) Logger() logger.Logger

Logger AFAIRE.

func (*Components) Model

func (cs *Components) Model() components.Model

Model AFAIRE.

func (*Components) Router

func (cs *Components) Router() components.Router

Router AFAIRE.

type Config

type Config interface {
	components.Config
}

Config AFAIRE.

type Crypto

type Crypto interface {
	components.Crypto
}

Crypto AFAIRE.

type Leader

type Leader interface {
	components.Leader
	Start()
	Stop()
}

Leader AFAIRE.

type Manager

type Manager interface {
	GetComponent(category string, mustExist bool) (minikit.Component, error)
}

Manager AFAIRE.

type Metrics

type Metrics interface {
	metrics.Metrics
}

Metrics AFAIRE.

type Model

type Model interface {
	components.Model
	ChannelJW() chan<- *message.Message
	NextJob() *jw.Job
	Clean()
}

Model AFAIRE.

type Router

type Router interface {
	components.Router
	Handler() http.Handler
}

Router AFAIRE.

type Scheduler

type Scheduler interface {
	Start()
	Stop()
}

Scheduler AFAIRE.

type Server

type Server interface {
	Port() int
	Start() error
	Stop()
}

Server AFAIRE.

type Workers

type Workers interface {
	Start()
	Stop()
}

Workers AFAIRE.