Versions in this module Expand all Collapse all v0 v0.5.0 Oct 28, 2024 v0.4.1 Nov 21, 2024 v0.4.0 Sep 2, 2024 v0.3.1 Nov 21, 2024 v0.3.0 Aug 22, 2024 v0.2.1 Nov 21, 2024 v0.2.0 Jul 16, 2024 Changes in this version + 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 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 CapabilityResponse + Err error type CapabilityType + func (c CapabilityType) String() string type TriggerEvent + Metadata values.Value + Payload values.Value + Timestamp string v0.1.1 Nov 12, 2024 v0.0.1 Nov 21, 2024 Changes in this version + const DefaultBatchCollectionPeriod + const DefaultBatchSize + const DefaultMessageExpiry + const DefaultRegistrationExpiry + const DefaultRegistrationRefresh + var ErrStopExecution = &errStopExecution + 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 ActionCapability interface + type BaseCapability interface + Info func(ctx context.Context) (CapabilityInfo, error) + type CapabilityConfiguration struct + DefaultConfig *values.Map + RemoteTargetConfig *RemoteTargetConfig + RemoteTriggerConfig *RemoteTriggerConfig + type CapabilityInfo struct + CapabilityType CapabilityType + DON *DON + Description string + ID string + IsLocal bool + 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 + Value *values.Map + type CapabilityType string + const CapabilityTypeAction + const CapabilityTypeConsensus + const CapabilityTypeTarget + const CapabilityTypeTrigger + const CapabilityTypeUnknown + func (c CapabilityType) IsValid() error + type ConsensusCapability interface + type DON struct + AcceptsWorkflows bool + ConfigVersion uint32 + F uint8 + ID uint32 + IsPublic bool + Members []p2ptypes.PeerID + 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 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 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 struct + ReferenceID string + WorkflowDonConfigVersion uint32 + WorkflowDonID uint32 + WorkflowExecutionID string + WorkflowID string + WorkflowName string + WorkflowOwner string + type TargetCapability interface + type TriggerCapability interface + type TriggerEvent struct + ID string + Outputs *values.Map + TriggerType string + type TriggerExecutable interface + RegisterTrigger func(ctx context.Context, request TriggerRegistrationRequest) (<-chan TriggerResponse, error) + UnregisterTrigger func(ctx context.Context, request TriggerRegistrationRequest) error + type TriggerRegistrationRequest struct + Config *values.Map + Metadata RequestMetadata + TriggerID string + type TriggerResponse struct + Err error + Event TriggerEvent + 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 v0.0.1-beta Nov 26, 2024
Go to main page