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 RegisterExecutableCapabilityServer(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) (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 ConsensusCapabilityClient
  • func (c ConsensusCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (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 ExecutableCapability
  • func NewExecutableCapabilityClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) ExecutableCapability
• type ExecutableCapabilityClient
  • func (c ExecutableCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error)
  • func (c ExecutableCapabilityClient) Info(ctx context.Context) (capabilities.CapabilityInfo, error)
  • func (c ExecutableCapabilityClient) RegisterToWorkflow(ctx context.Context, req capabilities.RegisterToWorkflowRequest) error
  • func (c ExecutableCapabilityClient) UnregisterFromWorkflow(ctx context.Context, req capabilities.UnregisterFromWorkflowRequest) error
• type TargetCapabilityClient
  • func (c TargetCapabilityClient) Execute(ctx context.Context, req capabilities.CapabilityRequest) (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.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error)
  • func (t TriggerCapabilityClient) UnregisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) 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 RegisterExecutableCapabilityServer

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

type ExecutableCapability interface {
	capabilities.Executable
	capabilities.BaseCapability
}

func NewExecutableCapabilityClient

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

type ExecutableCapabilityClient

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

func (ExecutableCapabilityClient) Execute

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

func (ExecutableCapabilityClient) Info

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

func (ExecutableCapabilityClient) RegisterToWorkflow

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

func (ExecutableCapabilityClient) UnregisterFromWorkflow

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