Documentation
¶
Index ¶
- type Capability
- type CapabilityWrapper
- func (c *CapabilityWrapper) Execute(ctx context.Context, request capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error)
- func (c *CapabilityWrapper) Info(_ context.Context) (capabilities.CapabilityInfo, error)
- func (c *CapabilityWrapper) RegisterToWorkflow(_ context.Context, _ capabilities.RegisterToWorkflowRequest) error
- func (c *CapabilityWrapper) RegisterTrigger(ctx context.Context, request capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error)
- func (c *CapabilityWrapper) UnregisterFromWorkflow(_ context.Context, _ capabilities.UnregisterFromWorkflowRequest) error
- func (c *CapabilityWrapper) UnregisterTrigger(_ context.Context, _ capabilities.TriggerRegistrationRequest) error
- type ErrNoTriggerStub
- type FakeWrapper
- type Registry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Capability ¶
type Capability interface {
Invoke(ctx context.Context, request *pb.CapabilityRequest) *pb.CapabilityResponse
InvokeTrigger(ctx context.Context, request *pb.TriggerSubscription) (*pb.Trigger, error)
ID() string
}
type CapabilityWrapper ¶
type CapabilityWrapper struct {
Capability
}
func (*CapabilityWrapper) Execute ¶
func (c *CapabilityWrapper) Execute(ctx context.Context, request capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error)
func (*CapabilityWrapper) Info ¶
func (c *CapabilityWrapper) Info(_ context.Context) (capabilities.CapabilityInfo, error)
func (*CapabilityWrapper) RegisterToWorkflow ¶
func (c *CapabilityWrapper) RegisterToWorkflow(_ context.Context, _ capabilities.RegisterToWorkflowRequest) error
func (*CapabilityWrapper) RegisterTrigger ¶
func (c *CapabilityWrapper) RegisterTrigger(ctx context.Context, request capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error)
func (*CapabilityWrapper) UnregisterFromWorkflow ¶
func (c *CapabilityWrapper) UnregisterFromWorkflow(_ context.Context, _ capabilities.UnregisterFromWorkflowRequest) error
func (*CapabilityWrapper) UnregisterTrigger ¶
func (c *CapabilityWrapper) UnregisterTrigger(_ context.Context, _ capabilities.TriggerRegistrationRequest) error
type ErrNoTriggerStub ¶
type ErrNoTriggerStub string
func (ErrNoTriggerStub) Error ¶
func (n ErrNoTriggerStub) Error() string
type FakeWrapper ¶
type FakeWrapper struct {
capabilities.BaseCapability
// contains filtered or unexported fields
}
func NewFakeWrapper ¶
func NewFakeWrapper(tb testing.TB, capability capabilities.BaseCapability) (*FakeWrapper, error)
func (*FakeWrapper) ID ¶
func (f *FakeWrapper) ID() string
func (*FakeWrapper) Invoke ¶
func (f *FakeWrapper) Invoke(ctx context.Context, request *pb.CapabilityRequest) *pb.CapabilityResponse
func (*FakeWrapper) InvokeTrigger ¶
func (f *FakeWrapper) InvokeTrigger(ctx context.Context, request *pb.TriggerSubscription) (*pb.Trigger, error)
type Registry ¶
type Registry struct {
core.CapabilitiesRegistryBase
// contains filtered or unexported fields
}
Registry is meant to be used with GetRegistry, do not use it directly.
func GetRegistry ¶
func (*Registry) GetCapability ¶
func (r *Registry) GetCapability(id string) (Capability, error)
func (*Registry) RegisterCapability ¶
func (r *Registry) RegisterCapability(c Capability) error
Source Files
Click to show internal directories.
Click to hide internal directories.