runtime

Documentation

Index

• type Configuration
  • func WithController(controller Controller) Configuration[*MultiRuntime]
  • func WithRuntime(runtime Runtime) Configuration[*MultiRuntime]
• type ContextKey
  • func Context(name string) ContextKey
• type Controller
  • func NewController() Controller
• type MultiRuntime
  • func (runtime *MultiRuntime) Interrupt()
  • func (runtime *MultiRuntime) Panic()
  • func (r *MultiRuntime) Start() error
  • func (r *MultiRuntime) Stop()
• type Producer
• type Runtime
  • func NewMulti(configurations ...Configuration[*MultiRuntime]) Runtime
• type RuntimeController
  • func (c *RuntimeController) Started()
  • func (c *RuntimeController) Stopped()
  • func (c *RuntimeController) Wait()

Types

type Configuration

type Configuration[R any] func(R) R

func WithController

func WithController(controller Controller) Configuration[*MultiRuntime]

configuration

func WithRuntime

func WithRuntime(runtime Runtime) Configuration[*MultiRuntime]

type ContextKey

type ContextKey struct {
	Name string
}

func Context

func Context(name string) ContextKey

type Controller

type Controller interface {
	Started() // denotes that a runtime element has started
	Stopped() // denotes that a runtime element has stopped
	Wait()
}

func NewController

func NewController() Controller

type MultiRuntime

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

implementation

func (*MultiRuntime) Interrupt

func (runtime *MultiRuntime) Interrupt()

func (*MultiRuntime) Panic

func (runtime *MultiRuntime) Panic()

func (*MultiRuntime) Start

func (r *MultiRuntime) Start() error

func (*MultiRuntime) Stop

func (r *MultiRuntime) Stop()

type Producer

type Producer interface {
	Produce(context.Context, []message.Message[message.Bytes, message.Bytes]) error
	Start() error
	Stop()
}

type Runtime

type Runtime interface {
	Start() error
	Stop()
}

func NewMulti

func NewMulti(configurations ...Configuration[*MultiRuntime]) Runtime

constructor

type RuntimeController

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

func (*RuntimeController) Started

func (c *RuntimeController) Started()

func (*RuntimeController) Stopped

func (c *RuntimeController) Stopped()

func (*RuntimeController) Wait

func (c *RuntimeController) Wait()