control

package

v1.0.13 Latest Latest Go to latest Published: Jan 5, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/criteo/traffic-mirroring

Links

Open Source Insights

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 ¶

View Source

const (
	DecoupleName = "control.decouple"
)

View Source

const (
	FanoutName = "control.fanout"
)

View Source

const (
	IdentityName = "control.identity"
)

View Source

const (
	RateLimitName = "control.rate_limit"
)

View Source

const (
	SeqName = "control.seq"
)

View Source

const (
	SplitByName = "control.split_by"
)

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL