capability

Documentation

Index

• func InfoReplyToInfo(resp *capabilitiespb.CapabilityInfoReply) (capabilities.CapabilityInfo, error)
• func InfoToReply(info capabilities.CapabilityInfo) *capabilitiespb.CapabilityInfoReply
• func NewActionCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.ActionCapability
• func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface, b *net.BrokerExt) *capabilitiesRegistryClient
• func NewCapabilitiesRegistryServer(b *net.BrokerExt, i core.CapabilitiesRegistry) *capabilitiesRegistryServer
• func NewConsensusCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.ConsensusCapability
• func NewTargetCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.TargetCapability
• func NewTriggerCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) capabilities.TriggerCapability
• func RegisterCallbackCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
• func RegisterTriggerCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
• type ActionCapabilityClient
  • func (c ActionCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
  • func (c ActionCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (c ActionCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error
  • func (c ActionCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error
• type CallbackCapability
  • func NewCallbackCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) CallbackCapability
• type CallbackCapabilityClient
  • func (c CallbackCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
  • func (c CallbackCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (c CallbackCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error
  • func (c CallbackCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error
• type ConsensusCapabilityClient
  • func (c ConsensusCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
  • func (c ConsensusCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (c ConsensusCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error
  • func (c ConsensusCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error
• type TargetCapabilityClient
  • func (c TargetCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
  • func (c TargetCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (c TargetCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error
  • func (c TargetCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error
• type TriggerCapabilityClient
  • func (c TriggerCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (t TriggerCapabilityClient) RegisterTrigger(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
  • func (t TriggerCapabilityClient) UnregisterTrigger(ctx context.Context, req capabilities.CapabilityRequest) error

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 RegisterCallbackCapabilityServer

func RegisterCallbackCapabilityServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl CallbackCapability) 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) (<-chan 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 CallbackCapability

type CallbackCapability interface {
	capabilities.CallbackExecutable
	capabilities.BaseCapability
}

func NewCallbackCapabilityClient

func NewCallbackCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) CallbackCapability

type CallbackCapabilityClient

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

func (CallbackCapabilityClient) Execute

func (c CallbackCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)

func (CallbackCapabilityClient) Info

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

func (CallbackCapabilityClient) RegisterToWorkflow

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

func (CallbackCapabilityClient) UnregisterFromWorkflow

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

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

func (TargetCapabilityClient) Execute

func (c TargetCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan 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.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)

func (TriggerCapabilityClient) UnregisterTrigger

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