capability

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 9, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

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 NewActionCapabilityClient 

func NewActionCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.ActionCapability

func NewCapabilitiesRegistryClient 

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

func NewCapabilitiesRegistryServer 

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

func NewConsensusCapabilityClient 

func NewConsensusCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.ConsensusCapability

func NewTargetCapabilityClient 

func NewTargetCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.TargetCapability

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 ActionCapabilityClient 

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

func (ActionCapabilityClient) Execute 

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

func (ActionCapabilityClient) Info 

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

func (ActionCapabilityClient) RegisterToWorkflow 

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

func (ActionCapabilityClient) UnregisterFromWorkflow 

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

type ConsensusCapabilityClient 

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

func (ConsensusCapabilityClient) Execute 

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

func (ConsensusCapabilityClient) Info 

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

func (ConsensusCapabilityClient) RegisterToWorkflow 

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

func (ConsensusCapabilityClient) UnregisterFromWorkflow 

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

type ExecutableCapability added in v0.2.2 

type ExecutableCapability interface {
	capabilities.Executable
	capabilities.BaseCapability
}

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 TargetCapabilityClient 

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

func (TargetCapabilityClient) Execute 

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

func (TargetCapabilityClient) Info 

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

func (TargetCapabilityClient) RegisterToWorkflow 

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

func (TargetCapabilityClient) UnregisterFromWorkflow 

func (c TargetCapabilityClient) 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
test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.