api

Documentation

Index

• func New(size int, metrics *metrics.Metrics) *api
• type API
• type Subsystem

Functions

func New

func New(size int, metrics *metrics.Metrics) *api

Types

type API

type API interface {
	String() string

	Start() error
	Stop() error
	Shutdown()
	Done() bool
	Errors() <-chan error

	Signal(<-chan interface{}) <-chan interface{}

	EnqueueSQE(*bus.SQE[t_api.Request, t_api.Response])
	DequeueSQE(int) []*bus.SQE[t_api.Request, t_api.Response]
	EnqueueCQE(*bus.CQE[t_api.Request, t_api.Response])
	DequeueCQE(<-chan *bus.CQE[t_api.Request, t_api.Response]) *bus.CQE[t_api.Request, t_api.Response]
}

type Subsystem

type Subsystem interface {
	String() string
	Kind() string
	Addr() string
	Start(chan<- error)
	Stop() error
}