unmanaged

Documentation

Overview

Internal package with the implementation of a discipline that does not manage data according to their priority.

Index

• Variables
• type Discipline
  • func New[Type any](opts Opts[Type]) (*Discipline[Type], error)
  • func (dsc *Discipline[Type]) Err() <-chan error
  • func (dsc *Discipline[Type]) Output() <-chan types.Prioritized[Type]
  • func (dsc *Discipline[Type]) Release(uint)
• type Opts

Variables

var (
	ErrFalseError = errors.New("false error")
)

Types

type Discipline

type Discipline[Type any] struct {
	// contains filtered or unexported fields
}

func New

func New[Type any](opts Opts[Type]) (*Discipline[Type], error)

func (*Discipline[Type]) Err

func (dsc *Discipline[Type]) Err() <-chan error

func (*Discipline[Type]) Output

func (dsc *Discipline[Type]) Output() <-chan types.Prioritized[Type]

func (*Discipline[Type]) Release

func (dsc *Discipline[Type]) Release(uint)

type Opts

type Opts[Type any] struct {
	FailAt           uint
	HandlersQuantity uint
	Inputs           map[uint]<-chan Type
}