control

Documentation

Index

• Constants
• func NewDecouple(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewFanout(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewIdentity(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewRateLimit(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewSeq(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewSplitBy(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewVirtual(ctx *mirror.ModuleContext) mirror.Module
• type Decouple
  • func (m *Decouple) Children() [][]mirror.Module
  • func (m *Decouple) Context() *mirror.ModuleContext
  • func (m *Decouple) Output() <-chan mirror.Request
  • func (m *Decouple) SetInput(c <-chan mirror.Request)
• type DecoupleConfig
• type Fanout
  • func (m *Fanout) Children() [][]mirror.Module
  • func (m *Fanout) Context() *mirror.ModuleContext
  • func (m *Fanout) Output() <-chan mirror.Request
  • func (m *Fanout) SetInput(c <-chan mirror.Request)
• type Identity
  • func (m *Identity) Children() [][]mirror.Module
  • func (m *Identity) Context() *mirror.ModuleContext
  • func (m *Identity) Output() <-chan mirror.Request
  • func (m *Identity) SetInput(c <-chan mirror.Request)
• type RateLimit
  • func (m *RateLimit) Children() [][]mirror.Module
  • func (m *RateLimit) Context() *mirror.ModuleContext
  • func (m *RateLimit) Output() <-chan mirror.Request
  • func (m *RateLimit) SetInput(c <-chan mirror.Request)
• type RateLimitConfig
• type Seq
  • func (m *Seq) Children() [][]mirror.Module
  • func (m *Seq) Context() *mirror.ModuleContext
  • func (m *Seq) Output() <-chan mirror.Request
  • func (m *Seq) SetInput(c <-chan mirror.Request)
• type SplitBy
  • func (m *SplitBy) Children() [][]mirror.Module
  • func (m *SplitBy) Context() *mirror.ModuleContext
  • func (m *SplitBy) Output() <-chan mirror.Request
  • func (m *SplitBy) SetInput(c <-chan mirror.Request)
• type SplitByConfig
• type Virtual
  • func (m *Virtual) Children() [][]mirror.Module
  • func (m *Virtual) Context() *mirror.ModuleContext
  • func (m *Virtual) Output() <-chan mirror.Request
  • func (m *Virtual) SetInput(c <-chan mirror.Request)

Constants

const (
	DecoupleName = "control.decouple"
)

const (
	FanoutName = "control.fanout"
)

const (
	IdentityName = "control.identity"
)

const (
	RateLimitName = "control.rate_limit"
)

const (
	SeqName = "control.seq"
)

const (
	SplitByName = "control.split_by"
)

Functions

func NewDecouple

func NewDecouple(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewFanout

func NewFanout(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewIdentity

func NewIdentity(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewRateLimit

func NewRateLimit(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewSeq

func NewSeq(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewSplitBy

func NewSplitBy(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewVirtual

func NewVirtual(ctx *mirror.ModuleContext) mirror.Module

Types

type Decouple

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

func (*Decouple) Children

func (m *Decouple) Children() [][]mirror.Module

func (*Decouple) Context

func (m *Decouple) Context() *mirror.ModuleContext

func (*Decouple) Output

func (m *Decouple) Output() <-chan mirror.Request

func (*Decouple) SetInput

func (m *Decouple) SetInput(c <-chan mirror.Request)

type DecoupleConfig

type DecoupleConfig struct {
	Quiet     bool `json:"log"`
	QueueSize int  `json:"queue_size"`
}

type Fanout

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

func (*Fanout) Children

func (m *Fanout) Children() [][]mirror.Module

func (*Fanout) Context

func (m *Fanout) Context() *mirror.ModuleContext

func (*Fanout) Output

func (m *Fanout) Output() <-chan mirror.Request

func (*Fanout) SetInput

func (m *Fanout) SetInput(c <-chan mirror.Request)

type Identity

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

func (*Identity) Children

func (m *Identity) Children() [][]mirror.Module

func (*Identity) Context

func (m *Identity) Context() *mirror.ModuleContext

func (*Identity) Output

func (m *Identity) Output() <-chan mirror.Request

func (*Identity) SetInput

func (m *Identity) SetInput(c <-chan mirror.Request)

type RateLimit

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

func (*RateLimit) Children

func (m *RateLimit) Children() [][]mirror.Module

func (*RateLimit) Context

func (m *RateLimit) Context() *mirror.ModuleContext

func (*RateLimit) Output

func (m *RateLimit) Output() <-chan mirror.Request

func (*RateLimit) SetInput

func (m *RateLimit) SetInput(c <-chan mirror.Request)

type RateLimitConfig

type RateLimitConfig struct {
	RPS *expr.NumberExpr `json:"rps"`
}

type Seq

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

func (*Seq) Children

func (m *Seq) Children() [][]mirror.Module

func (*Seq) Context

func (m *Seq) Context() *mirror.ModuleContext

func (*Seq) Output

func (m *Seq) Output() <-chan mirror.Request

func (*Seq) SetInput

func (m *Seq) SetInput(c <-chan mirror.Request)

type SplitBy

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

func (*SplitBy) Children

func (m *SplitBy) Children() [][]mirror.Module

func (*SplitBy) Context

func (m *SplitBy) Context() *mirror.ModuleContext

func (*SplitBy) Output

func (m *SplitBy) Output() <-chan mirror.Request

func (*SplitBy) SetInput

func (m *SplitBy) SetInput(c <-chan mirror.Request)

type SplitByConfig

type SplitByConfig struct {
	Expr     *expr.AnyExpr   `json:"expr,omitempty"`
	Pipeline json.RawMessage `json:"pipeline,omitempty"`
}

type Virtual

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

func (*Virtual) Children

func (m *Virtual) Children() [][]mirror.Module

func (*Virtual) Context

func (m *Virtual) Context() *mirror.ModuleContext

func (*Virtual) Output

func (m *Virtual) Output() <-chan mirror.Request

func (*Virtual) SetInput

func (m *Virtual) SetInput(c <-chan mirror.Request)