capabilities

package

Go to main page

Versions in this module

v0

v0.4.1

Jan 16, 2025

Changes in this version

type RemoteExecutableConfig

+ RegistrationExpiry time.Duration

+ RegistrationRefresh time.Duration

+ func (c *RemoteExecutableConfig) ApplyDefaults()

type RequestMetadata

+ DecodedWorkflowName string

v0.4.0

Dec 14, 2024

Changes in this version

type CapabilityConfiguration

+ RemoteExecutableConfig *RemoteExecutableConfig

type RegistrationMetadata

+ ReferenceID string

+ type RemoteExecutableConfig struct

+ RequestHashExcludedAttributes []string

v0.3.1-beholder

Nov 21, 2024

v0.3.0

Oct 9, 2024

v0.2.2

Sep 17, 2024

Changes in this version

+ const DefaultBatchCollectionPeriod

+ const DefaultBatchSize

+ const DefaultMessageExpiry

+ const DefaultRegistrationExpiry

+ const DefaultRegistrationRefresh

+ var PromExecutionTimeMS = promauto.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ var PromTaskRunFaultCount = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PromTaskRunInvalidCount = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PromTaskRunNoResourceCount = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PromTaskRunSuccessCount = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PromTaskRunUnauthorizedCount = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ type CapabilityConfiguration struct

+ DefaultConfig *values.Map

+ RemoteTargetConfig *RemoteTargetConfig

+ RemoteTriggerConfig *RemoteTriggerConfig

type CapabilityInfo

+ IsLocal bool

type CapabilityType

+ const CapabilityTypeUnknown

+ type Executable interface

+ Execute func(ctx context.Context, request CapabilityRequest) (CapabilityResponse, error)

+ RegisterToWorkflow func(ctx context.Context, request RegisterToWorkflowRequest) error

+ UnregisterFromWorkflow func(ctx context.Context, request UnregisterFromWorkflowRequest) error

+ type ExecutableCapability interface

+ type RemoteTargetConfig struct

+ RequestHashExcludedAttributes []string

+ type RemoteTriggerConfig struct

+ BatchCollectionPeriod time.Duration

+ MaxBatchSize uint32

+ MessageExpiry time.Duration

+ MinResponsesToAggregate uint32

+ RegistrationExpiry time.Duration

+ RegistrationRefresh time.Duration

+ func (c *RemoteTriggerConfig) ApplyDefaults()

type RequestMetadata

+ ReferenceID string

type TriggerEvent

+ Outputs *values.Map

+ type TriggerRegistrationRequest struct

+ Config *values.Map

+ Metadata RequestMetadata

+ TriggerID string

+ type TriggerResponse struct

+ Err error

+ Event TriggerEvent

v0.2.1

Jul 18, 2024

v0.2.0

Jul 15, 2024

Changes in this version

+ var ErrStopExecution = &errStopExecution

+ func ExecuteSync(ctx context.Context, c CallbackExecutable, request CapabilityRequest) (*values.List, error)

+ func ExecuteSyncWithTimeout(ctx context.Context, c CallbackExecutable, request CapabilityRequest, ...) (*values.List, error)

+ type ActionCapability interface

+ type BaseCapability interface

+ Info func(ctx context.Context) (CapabilityInfo, error)

+ type CallbackCapability interface

+ type CallbackExecutable interface

+ Execute func(ctx context.Context, request CapabilityRequest) (<-chan CapabilityResponse, error)

+ RegisterToWorkflow func(ctx context.Context, request RegisterToWorkflowRequest) error

+ UnregisterFromWorkflow func(ctx context.Context, request UnregisterFromWorkflowRequest) error

+ type CapabilityInfo struct

+ CapabilityType CapabilityType

+ DON *DON

+ Description string

+ ID string

+ func MustNewCapabilityInfo(id string, capabilityType CapabilityType, description string) CapabilityInfo

+ func MustNewRemoteCapabilityInfo(id string, capabilityType CapabilityType, description string, don *DON) CapabilityInfo

+ func NewCapabilityInfo(id string, capabilityType CapabilityType, description string) (CapabilityInfo, error)

+ func NewRemoteCapabilityInfo(id string, capabilityType CapabilityType, description string, don *DON) (CapabilityInfo, error)

+ func (c CapabilityInfo) Info(ctx context.Context) (CapabilityInfo, error)

+ func (c CapabilityInfo) Version() string

+ type CapabilityRequest struct

+ Config *values.Map

+ Inputs *values.Map

+ Metadata RequestMetadata

+ type CapabilityResponse struct

+ Err error

+ Value *values.Map

+ type CapabilityType int

+ const CapabilityTypeAction

+ const CapabilityTypeConsensus

+ const CapabilityTypeTarget

+ const CapabilityTypeTrigger

+ func (c CapabilityType) IsValid() error

+ func (c CapabilityType) String() string

+ type ConsensusCapability interface

+ type DON struct

+ AcceptsWorkflows bool

+ ConfigVersion uint32

+ F uint8

+ ID uint32

+ IsPublic bool

+ Members []p2ptypes.PeerID

+ type Node struct

+ CapabilityDONs []DON

+ PeerID *p2ptypes.PeerID

+ WorkflowDON DON

+ type RegisterToWorkflowRequest struct

+ Config *values.Map

+ Metadata RegistrationMetadata

+ type RegistrationMetadata struct

+ WorkflowID string

+ WorkflowOwner string

+ type RequestMetadata struct

+ WorkflowDonConfigVersion uint32

+ WorkflowDonID uint32

+ WorkflowExecutionID string

+ WorkflowID string

+ WorkflowName string

+ WorkflowOwner string

+ type TargetCapability interface

+ type TriggerCapability interface

+ type TriggerEvent struct

+ ID string

+ Metadata values.Value

+ Payload values.Value

+ Timestamp string

+ TriggerType string

+ type TriggerExecutable interface

+ RegisterTrigger func(ctx context.Context, request CapabilityRequest) (<-chan CapabilityResponse, error)

+ UnregisterTrigger func(ctx context.Context, request CapabilityRequest) error

+ type UnregisterFromWorkflowRequest struct

+ Config *values.Map

+ Metadata RegistrationMetadata

+ type Validatable interface

+ Schema func() (string, error)

+ type Validator struct

+ func NewValidator[Config any, Inputs any, Outputs any](args ValidatorArgs) Validator[Config, Inputs, Outputs]

+ func (v *Validator[Config, Inputs, Outputs]) ConfigSchema() (string, error)

+ func (v *Validator[Config, Inputs, Outputs]) InputsSchema() (string, error)

+ func (v *Validator[Config, Inputs, Outputs]) OutputsSchema() (string, error)

+ func (v *Validator[Config, Inputs, Outputs]) Schema() (string, error)

+ func (v *Validator[Config, Inputs, Outputs]) ValidateConfig(config *values.Map) (*Config, error)

+ func (v *Validator[Config, Inputs, Outputs]) ValidateInputs(inputs *values.Map) (*Inputs, error)

+ func (v *Validator[Config, Inputs, Outputs]) ValidateOutputs(outputs *values.Map) (*Outputs, error)

+ type ValidatorArgs struct

+ ConfigReflector *jsonschema.Reflector

+ DefaultReflector *jsonschema.Reflector

+ Info CapabilityInfo

+ InputsReflector *jsonschema.Reflector

+ OutputsReflector *jsonschema.Reflector

+ SchemaReflector *jsonschema.Reflector

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