falco

package module

Go to main page

Versions in this module

v0

v0.2.2

Feb 25, 2021

Changes in this version

+ type AIMDLimiter struct

+ A float64

+ B float64

+ MaxRate int

+ Thr uint64

+ func NewAMIDLimiter(thr uint64, A, B float64, maxRPS int, clock LimiterClock) *AIMDLimiter

+ func (a *AIMDLimiter) Setup(ctx context.Context)

+ func (p AIMDLimiter) Signal(tick *time.Time)

+ func (p AIMDLimiter) Take(ctx context.Context) (*time.Time, error)

+ func (q AIMDLimiter) Query(ctx context.Context) (*time.Time, error)

type AsyncInvocationPhase

+ func (j *AsyncInvocationPhase) IsCanceled() <-chan struct{}

+ type CongestionController interface

+ Query func(ctx context.Context) (*time.Time, error)

+ Setup func(ctx context.Context)

+ Signal func(took *time.Time)

+ Take func(ctx context.Context) (*time.Time, error)

type Invocation

+ func NewMockInvocation(s string, args map[string]interface{}) Invocation

+ type LimiterClock interface

+ Now func() time.Time

+ Tick func() <-chan time.Time

+ func NewTimedClock(d time.Duration) LimiterClock

type MockInvocation

+ Args map[string]interface{}

+ func (m *MockInvocation) InvocationID() string

+ type PIDLimiter struct

+ D float64

+ F float64

+ I float64

+ MaxOpenRequests int

+ P float64

+ TargetRPS int

+ func NewPIDLimiter(P, I, D, F float64, targetRPS, maxOpen int, clock LimiterClock) *PIDLimiter

+ func (p *PIDLimiter) Setup(ctx context.Context)

+ func (p PIDLimiter) Signal(tick *time.Time)

+ func (p PIDLimiter) Take(ctx context.Context) (*time.Time, error)

+ func (q PIDLimiter) Query(ctx context.Context) (*time.Time, error)

+ type TimerClock struct

+ func (t *TimerClock) Now() time.Time

+ func (t *TimerClock) Tick() <-chan time.Time

v0.2.1

Jan 11, 2021

Changes in this version

+ type AsyncInvocationPhase struct

+ Deployment Deployment

+ ID string

+ Payloads []Invocation

+ func NewPhase(ctx context.Context, id string, tasks []Invocation, requestsPerSeconds int, ...) *AsyncInvocationPhase

+ func (j *AsyncInvocationPhase) AsParentContext() context.Context

+ func (j *AsyncInvocationPhase) Canceled() <-chan struct{}

+ func (j *AsyncInvocationPhase) Done(payloadID string)

+ func (j *AsyncInvocationPhase) Finish()

+ func (j *AsyncInvocationPhase) Log(text string)

+ func (j *AsyncInvocationPhase) Name() string

+ func (j *AsyncInvocationPhase) PrintStats()

+ func (j *AsyncInvocationPhase) SubmittedPayloadFromId(payloadID string) (Invocation, error)

+ func (j *AsyncInvocationPhase) SubmittedTask(payload Invocation)

+ func (j *AsyncInvocationPhase) TakeInvocation() time.Time

+ func (j *AsyncInvocationPhase) TakeQuery() time.Time

+ func (j *AsyncInvocationPhase) Wait()

+ func (j *AsyncInvocationPhase) WithTimeout(timeout time.Duration) error

+ type AsyncPlatform interface

+ Collect func(*AsyncInvocationPhase, <-chan Invocation, ...InvocableOptions) error

+ FetchActivationLog func(deployment Deployment, invocation Invocation) map[string]interface{}

+ Submit func(*AsyncInvocationPhase, Deployment, Invocation, chan<- Invocation, ...) error

type Deployable

+ func NewStringDeployable(payload string, runtime Runtime) Deployable

+ Option func() *Options

type Deployment

+ DeploymentID func() string

+ type Driver interface

+ Deploy func(platform AsyncPlatform)

+ Execute func(strategy ExecutionStrategy, platform AsyncPlatform) error

+ ExecutionPlan func() *ExecutionPlan

+ Remove func(platform AsyncPlatform)

+ Runtime func() Runtime

+ Strategies func() []ExecutionStrategy

+ type ExecutionPlan struct

+ Deployable Deployable

+ Phase *AsyncInvocationPhase

+ func NewExecutionPlan(dep Deployable, task *AsyncInvocationPhase) *ExecutionPlan

+ func (e *ExecutionPlan) Append(plan *ExecutionPlan)

+ func (e *ExecutionPlan) Deploy(platform AsyncPlatform) (Deployment, error)

+ func (e *ExecutionPlan) GetDeployment() Deployment

+ func (e *ExecutionPlan) ListRemaining() []*ExecutionPlan

+ func (e *ExecutionPlan) Next() *ExecutionPlan

+ func (e *ExecutionPlan) Remove(platform AsyncPlatform) error

+ func (e *ExecutionPlan) UseDeployment(platform AsyncPlatform, deploymentID string) (Deployment, error)

+ type Invocation interface

+ Done func(duration *time.Duration)

+ Error func() error

+ GetNumberOfSubmissions func() int8

+ InvocationDuration func() time.Duration

+ InvocationID func() string

+ IsCompleted func() bool

+ MarkAsResubmitted func()

+ Result func() interface{}

+ Runtime func() Runtime

+ RuntimeReference func() interface{}

+ SetError func(err error)

+ SetResult func(result interface{})

+ SetRuntimeReference func(id interface{})

+ Submitted func() int8

+ SubmittedAt func() time.Time

+ func NewSimpleInvocation(id string, runtime Runtime) Invocation

type MockInvocation

+ func (m *MockInvocation) DeploymentID() string

+ func (m *MockInvocation) InvocationDuration() time.Duration

+ func (m *MockInvocation) Result() interface{}

+ func (m *MockInvocation) RuntimeReference() interface{}

+ func (m *MockInvocation) SetResult(result interface{})

+ func (m *MockInvocation) SetRuntimeReference(id interface{})

type MockRuntime

+ func (m *MockRuntime) Identifier() string

+ type Options struct

+ func NewFacloOptions(name string) *Options

+ func (r *Options) Bool(name string) bool

+ func (r *Options) Duration(name string, defaultValue time.Duration) time.Duration

+ func (r *Options) Int(name string, defaultValue int) int

+ func (r *Options) IsSet(name string) bool

+ func (r *Options) Name() string

+ func (r *Options) NewBoolOption(name string, value bool)

+ func (r *Options) NewDurationOption(name string, value time.Duration)

+ func (r *Options) NewIntOption(name string, value int)

+ func (r *Options) NewSliceOption(name string, value []string)

+ func (r *Options) NewStingOption(name, value string)

+ func (r *Options) PrefixMap(prefix string) map[string]string

+ func (r *Options) Slice(name string) []string

+ func (r *Options) String(name, defaultValue string) string

+ func (r *Options) ToMap() map[string]string

type Platform

+ FetchDeployment func(deplotmentID string) (Deployment, error)

+ Invoke func(Deployment, Invocation) (Invocation, error)

type Runtime

+ Identifier func() string

+ type SimpleInvocation struct

+ func (s *SimpleInvocation) Done(duration *time.Duration)

+ func (s *SimpleInvocation) Result() interface{}

+ func (s *SimpleInvocation) SetError(err error)

+ func (s *SimpleInvocation) SetResult(result interface{})

+ func (s SimpleInvocation) Error() error

+ func (s SimpleInvocation) GetNumberOfSubmissions() int8

+ func (s SimpleInvocation) InvocationDuration() time.Duration

+ func (s SimpleInvocation) InvocationID() string

+ func (s SimpleInvocation) IsCompleted() bool

+ func (s SimpleInvocation) MarkAsResubmitted()

+ func (s SimpleInvocation) Runtime() Runtime

+ func (s SimpleInvocation) RuntimeReference() interface{}

+ func (s SimpleInvocation) SetRuntimeReference(id interface{})

+ func (s SimpleInvocation) Submitted() int8

+ func (s SimpleInvocation) SubmittedAt() time.Time

+ type StringDeployable struct

+ func (ed StringDeployable) Option() *Options

+ func (ed StringDeployable) Payload() interface{}

+ func (ed StringDeployable) Runtime() Runtime

v0.2.0

Nov 17, 2020

Changes in this version

type InvocationPayload

+ Status func() InvocationStatus

+ type InvocationStatus int

+ const Failure

+ const MemoryError

+ const PlatformError

+ const RuntimeError

+ const Success

type MockInvocation

+ func (m *MockInvocation) Status() InvocationStatus

v0.1.11

Aug 25, 2020

v0.1.10

Aug 25, 2020

v0.1.9

Aug 25, 2020

Changes in this version

+ type InvocationStrategy interface

+ InvocationPayload func(context *Context, workdir string, files ...string) ([]InvocationPayload, error)

+ StrategyName func() string

+ StrategyUsage func() string

type MockRuntime

+ func (m *MockRuntime) InvocationStrategies() []InvocationStrategy

type Runtime

+ InvocationStrategies func() []InvocationStrategy

v0.1.8

Aug 21, 2020

v0.1.7

Aug 20, 2020

v0.1.6

Aug 18, 2020

Changes in this version

type Context

+ func (r *Context) AsMap() map[string]interface{}

+ func (r *Context) Insert(prefix string, values map[string]interface{})

v0.1.5

Aug 14, 2020

Changes in this version

type Deployable

+ Name func() string

v0.1.4

Aug 14, 2020

v0.1.3

Aug 14, 2020

v0.1.2

Aug 14, 2020

v0.1.1

Aug 14, 2020

v0.1.0

Aug 14, 2020

Changes in this version

+ type CSVCollector struct

+ func (c *CSVCollector) Add(data Measurement)

+ func (c *CSVCollector) Print()

+ func (c *CSVCollector) Write(outputfile string) error

+ type Context struct

+ func NewContext(name string) *Context

+ func (r *Context) Bool(name string) bool

+ func (r *Context) Duration(name string, defaultValue time.Duration) time.Duration

+ func (r *Context) Int(name string, defaultValue int) int

+ func (r *Context) IsSet(name string) bool

+ func (r *Context) Name() string

+ func (r *Context) NewBoolOption(name string, value bool)

+ func (r *Context) NewDurationOption(name string, value time.Duration)

+ func (r *Context) NewIntOption(name string, value int)

+ func (r *Context) NewSliceOption(name string, value []string)

+ func (r *Context) NewStingOption(name, value string)

+ func (r *Context) PrefixMap(prefix string) map[string]string

+ func (r *Context) Slice(name string) []string

+ func (r *Context) String(name, defaultValue string) string

+ func (r *Context) ToMap() map[string]string

+ type Deployable interface

+ Context func() *Context

+ Payload func() string

+ Runtime func() string

+ type Deployment interface

+ ID func() string

+ type ExecutionStrategy interface

+ Execute func(*Job, Submittable, ResultCollector) error

+ type InvocableOptions interface

+ Apply func()

+ type InvocationPayload interface

+ Done func()

+ Error func() error

+ GetNumberOfSubmissions func() int8

+ ID func() string

+ IsCompleted func() bool

+ Latancy func() time.Duration

+ MarkAsResubmitted func()

+ Runtime func() Runtime

+ SetError func(err error)

+ Submitted func() int8

+ SubmittedAt func() time.Time

+ WriteError func(writer ResultCollector)

+ type Invokable interface

+ Invoke func(Deployment, InvocationPayload, ResultCollector) error

+ type Job struct

+ Context Context

+ Deployment Deployment

+ Tasks []InvocationPayload

+ func NewJob(ctx context.Context, tasks []InvocationPayload, requestsPerSeconds int, ...) *Job

+ func (j *Job) AsParentContext() context.Context

+ func (j *Job) Cancel()

+ func (j *Job) Canceled() <-chan struct{}

+ func (j *Job) Done(payloadID string)

+ func (j *Job) Finish()

+ func (j *Job) Info(text string)

+ func (j *Job) Name() string

+ func (j *Job) PayloadFromId(payloadID string) (InvocationPayload, error)

+ func (j *Job) PrintStats()

+ func (j *Job) SubmittedTask(payload InvocationPayload)

+ func (j *Job) TakeQuery() time.Time

+ func (j *Job) TakeSpawn() time.Time

+ func (j *Job) Wait()

+ func (j *Job) WithTimeout(timeout time.Duration) error

+ type Measurable interface

+ MakeFailure func(id, cause string, start time.Time) Measurement

+ MakeMeasurement func(map[string]interface{}) Measurement

+ type Measurement map[string]interface

+ func (data Measurement) InvocationID() string

+ func (data Measurement) IsFailure() bool

+ func (data Measurement) JobID() string

+ func (data Measurement) SetInvocationID(name string)

+ func (data Measurement) SetJobID(name string)

+ func (data Measurement) SetRequestLatency(latency time.Duration)

+ func (m Measurement) WithDefaults() Measurement

+ type MockInvocation struct

+ COM time.Time

+ DONE bool

+ Delay time.Duration

+ ERR error

+ IID string

+ SUB time.Time

+ SuccessSelector func(invocation *MockInvocation) bool

+ Tries int8

+ func (m *MockInvocation) Done()

+ func (m *MockInvocation) Error() error

+ func (m *MockInvocation) GetNumberOfSubmissions() int8

+ func (m *MockInvocation) ID() string

+ func (m *MockInvocation) IsCompleted() bool

+ func (m *MockInvocation) Latancy() time.Duration

+ func (m *MockInvocation) MarkAsResubmitted()

+ func (m *MockInvocation) Runtime() Runtime

+ func (m *MockInvocation) SetError(err error)

+ func (m *MockInvocation) Submitted() int8

+ func (m *MockInvocation) SubmittedAt() time.Time

+ func (m *MockInvocation) Succeed() bool

+ func (m *MockInvocation) WriteError(writer ResultCollector)

+ type MockRuntime struct

+ func (m *MockRuntime) InvocationPayload(c *Context, s ...string) ([]InvocationPayload, error)

+ func (m *MockRuntime) MakeDeployment(c *Context, s ...string) (Deployable, error)

+ func (m *MockRuntime) MakeFailure(id, cause string, start time.Time) Measurement

+ func (m *MockRuntime) MakeMeasurement(m2 map[string]interface{}) Measurement

+ type MockWriter struct

+ func (m *MockWriter) Add(measurement Measurement)

+ func (m *MockWriter) Print()

+ func (m *MockWriter) Write(s string) error

+ type Monitor struct

+ func (m Monitor) Advance(i int)

+ func (m Monitor) Expand(i int)

+ func (m Monitor) Finish()

+ func (m Monitor) Info(s string)

+ func (m Monitor) Render()

+ func (m Monitor) Setup()

+ type Platform interface

+ Deploy func(deployable Deployable) (Deployment, error)

+ Remove func(deployment Deployment) error

+ Scale func(Deployment, ...ScaleOptions) (Deployment, error)

+ type ProgressMonitor interface

+ Advance func(int)

+ Expand func(int)

+ Finish func()

+ Info func(string)

+ Render func()

+ Setup func()

+ type ResultCollector interface

+ Add func(measurement Measurement)

+ Print func()

+ Write func(string2 string) error

+ func NewCollector() ResultCollector

+ type Runtime interface

+ InvocationPayload func(*Context, ...string) ([]InvocationPayload, error)

+ MakeDeployment func(*Context, ...string) (Deployable, error)

+ type ScaleOptions func(deployment Deployment)

+ type Submittable interface

+ Collect func(*Job, <-chan map[string]interface{}, ResultCollector, ...InvocableOptions) error

+ Submit func(*Job, InvocationPayload, chan<- map[string]interface{}, ...InvocableOptions) error

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