capability

package

v0.9.4 Latest Latest Go to latest Published: Sep 2, 2025 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/smartcontractkit/chainlink-common

Links

Open Source Insights

Documentation ¶

Index ¶

func InfoReplyToInfo(resp *capabilitiespb.CapabilityInfoReply) (capabilities.CapabilityInfo, error)
func InfoToReply(info capabilities.CapabilityInfo) *capabilitiespb.CapabilityInfoReply
func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface, b *net.BrokerExt) *capabilitiesRegistryClient
func NewCapabilitiesRegistryServer(b *net.BrokerExt, i core.CapabilitiesRegistry) *capabilitiesRegistryServer
func NewTriggerCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.TriggerCapability
func RegisterExecutableCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
func RegisterTriggerCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
type CombinedCapabilityClient
type ExecutableCapability
- func NewCombinedCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) ExecutableCapability
- func NewExecutableCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) ExecutableCapability
type ExecutableCapabilityClient
type TriggerCapabilityClient

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InfoReplyToInfo ¶

func InfoReplyToInfo(resp *capabilitiespb.CapabilityInfoReply) (capabilities.CapabilityInfo, error)

func InfoToReply ¶

func InfoToReply(info capabilities.CapabilityInfo) *capabilitiespb.CapabilityInfoReply

func NewCapabilitiesRegistryClient ¶

func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface, b *net.BrokerExt) *capabilitiesRegistryClient

func NewCapabilitiesRegistryServer ¶

func NewCapabilitiesRegistryServer(b *net.BrokerExt, i core.CapabilitiesRegistry) *capabilitiesRegistryServer

func NewTriggerCapabilityClient ¶

func NewTriggerCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.TriggerCapability

func RegisterExecutableCapabilityServer ¶ added in v0.2.2

func RegisterExecutableCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl ExecutableCapability) error

func RegisterTriggerCapabilityServer ¶

func RegisterTriggerCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl capabilities.TriggerCapability) error

Types ¶

type CombinedCapabilityClient ¶ added in v0.7.1

type CombinedCapabilityClient struct {
	// contains filtered or unexported fields
}

func (CombinedCapabilityClient) Execute ¶ added in v0.7.1

func (c CombinedCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error)

func (CombinedCapabilityClient) Info ¶ added in v0.7.1

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

func (CombinedCapabilityClient) RegisterToWorkflow ¶ added in v0.7.1

func (c CombinedCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error

func (CombinedCapabilityClient) RegisterTrigger ¶ added in v0.7.1

func (t CombinedCapabilityClient) RegisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error)

func (CombinedCapabilityClient) UnregisterFromWorkflow ¶ added in v0.7.1

func (c CombinedCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error

func (CombinedCapabilityClient) UnregisterTrigger ¶ added in v0.7.1

func (t CombinedCapabilityClient) UnregisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) error

type ExecutableCapability ¶ added in v0.2.2

type ExecutableCapability interface {
	capabilities.Executable
	capabilities.BaseCapability
}

func NewCombinedCapabilityClient ¶ added in v0.7.1

func NewCombinedCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) ExecutableCapability

func NewExecutableCapabilityClient ¶ added in v0.2.2

func NewExecutableCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) ExecutableCapability

type ExecutableCapabilityClient ¶ added in v0.2.2

type ExecutableCapabilityClient struct {
	// contains filtered or unexported fields
}

func (ExecutableCapabilityClient) Execute ¶ added in v0.2.2

func (c ExecutableCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error)

func (ExecutableCapabilityClient) Info ¶ added in v0.2.2

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

func (ExecutableCapabilityClient) RegisterToWorkflow ¶ added in v0.2.2

func (c ExecutableCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error

func (ExecutableCapabilityClient) UnregisterFromWorkflow ¶ added in v0.2.2

func (c ExecutableCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error

type TriggerCapabilityClient ¶

type TriggerCapabilityClient struct {
	// contains filtered or unexported fields
}

func (TriggerCapabilityClient) Info ¶

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

func (TriggerCapabilityClient) RegisterTrigger ¶

func (t TriggerCapabilityClient) RegisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error)

func (TriggerCapabilityClient) UnregisterTrigger ¶

func (t TriggerCapabilityClient) UnregisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
standard
test

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