pb

package

Go to main page

Versions in this module

v0

v0.9.6

Sep 26, 2025

v0.9.5

Sep 19, 2025

Changes in this version

+ var AggregatorType_name = map[int32]string

+ var AggregatorType_value = map[string]int32

+ var RequestHasherType_name = map[int32]string

+ var RequestHasherType_value = map[string]int32

+ var TransmissionSchedule_name = map[int32]string

+ var TransmissionSchedule_value = map[string]int32

+ type AggregatorConfig struct

+ AggregatorType AggregatorType

+ func (*AggregatorConfig) Descriptor() ([]byte, []int)

+ func (*AggregatorConfig) ProtoMessage()

+ func (x *AggregatorConfig) GetAggregatorType() AggregatorType

+ func (x *AggregatorConfig) ProtoReflect() protoreflect.Message

+ func (x *AggregatorConfig) Reset()

+ func (x *AggregatorConfig) String() string

+ type AggregatorType int32

+ const AggregatorType_Mode

+ const AggregatorType_SignedReport

+ func (AggregatorType) Descriptor() protoreflect.EnumDescriptor

+ func (AggregatorType) EnumDescriptor() ([]byte, []int)

+ func (AggregatorType) Type() protoreflect.EnumType

+ func (x AggregatorType) Enum() *AggregatorType

+ func (x AggregatorType) Number() protoreflect.EnumNumber

+ func (x AggregatorType) String() string

type CapabilityConfig

+ MethodConfigs map[string]*CapabilityMethodConfig

+ func (x *CapabilityConfig) GetMethodConfigs() map[string]*CapabilityMethodConfig

+ type CapabilityMethodConfig struct

+ AggregatorConfig *AggregatorConfig

+ RemoteConfig isCapabilityMethodConfig_RemoteConfig

+ func (*CapabilityMethodConfig) Descriptor() ([]byte, []int)

+ func (*CapabilityMethodConfig) ProtoMessage()

+ func (x *CapabilityMethodConfig) GetAggregatorConfig() *AggregatorConfig

+ func (x *CapabilityMethodConfig) GetRemoteConfig() isCapabilityMethodConfig_RemoteConfig

+ func (x *CapabilityMethodConfig) GetRemoteExecutableConfig() *RemoteExecutableConfig

+ func (x *CapabilityMethodConfig) GetRemoteTriggerConfig() *RemoteTriggerConfig

+ func (x *CapabilityMethodConfig) ProtoReflect() protoreflect.Message

+ func (x *CapabilityMethodConfig) Reset()

+ func (x *CapabilityMethodConfig) String() string

+ type CapabilityMethodConfig_RemoteExecutableConfig struct

+ RemoteExecutableConfig *RemoteExecutableConfig

+ type CapabilityMethodConfig_RemoteTriggerConfig struct

+ RemoteTriggerConfig *RemoteTriggerConfig

type RemoteExecutableConfig

+ DeltaStage *durationpb.Duration

+ RequestHasherType RequestHasherType

+ RequestTimeout *durationpb.Duration

+ ServerMaxParallelRequests uint32

+ TransmissionSchedule TransmissionSchedule

+ func (x *RemoteExecutableConfig) GetDeltaStage() *durationpb.Duration

+ func (x *RemoteExecutableConfig) GetRequestHasherType() RequestHasherType

+ func (x *RemoteExecutableConfig) GetRequestTimeout() *durationpb.Duration

+ func (x *RemoteExecutableConfig) GetServerMaxParallelRequests() uint32

+ func (x *RemoteExecutableConfig) GetTransmissionSchedule() TransmissionSchedule

+ type RequestHasherType int32

+ const RequestHasherType_Simple

+ const RequestHasherType_WriteReportExcludeSignatures

+ func (RequestHasherType) Descriptor() protoreflect.EnumDescriptor

+ func (RequestHasherType) EnumDescriptor() ([]byte, []int)

+ func (RequestHasherType) Type() protoreflect.EnumType

+ func (x RequestHasherType) Enum() *RequestHasherType

+ func (x RequestHasherType) Number() protoreflect.EnumNumber

+ func (x RequestHasherType) String() string

+ type TransmissionSchedule int32

+ const TransmissionSchedule_AllAtOnce

+ const TransmissionSchedule_OneAtATime

+ func (TransmissionSchedule) Descriptor() protoreflect.EnumDescriptor

+ func (TransmissionSchedule) EnumDescriptor() ([]byte, []int)

+ func (TransmissionSchedule) Type() protoreflect.EnumType

+ func (x TransmissionSchedule) Enum() *TransmissionSchedule

+ func (x TransmissionSchedule) Number() protoreflect.EnumNumber

+ func (x TransmissionSchedule) String() string

v0.9.4

Sep 2, 2025

v0.9.3

Aug 21, 2025

v0.9.2

Aug 21, 2025

v0.9.1

Aug 20, 2025

v0.9.0

Aug 8, 2025

Changes in this version

type RequestMetadata

+ WorkflowTag string

+ func (x *RequestMetadata) GetWorkflowTag() string

v0.8.0

Jul 14, 2025

v0.7.2

Aug 1, 2025

v0.7.1

Jul 28, 2025

Changes in this version

+ const CapabilityTypeCombined

+ var File_capabilities_proto protoreflect.FileDescriptor

+ var File_registry_proto protoreflect.FileDescriptor

+ var File_triggers_proto protoreflect.FileDescriptor

type CapabilityInfoReply

+ SpendTypes []string

+ func (x *CapabilityInfoReply) GetSpendTypes() []string

type CapabilityRequest

+ CapabilityId string

+ ConfigPayload *anypb.Any

+ Method string

+ Payload *anypb.Any

+ func (x *CapabilityRequest) GetCapabilityId() string

+ func (x *CapabilityRequest) GetConfigPayload() *anypb.Any

+ func (x *CapabilityRequest) GetMethod() string

+ func (x *CapabilityRequest) GetPayload() *anypb.Any

type CapabilityResponse

+ Payload *anypb.Any

+ func (x *CapabilityResponse) GetPayload() *anypb.Any

type CapabilityType

+ const CapabilityType_CAPABILITY_TYPE_COMBINED

type InitialiseRequest

+ GatewayConnectorId uint32

+ KeystoreId uint32

+ func (x *InitialiseRequest) GetGatewayConnectorId() uint32

+ func (x *InitialiseRequest) GetKeystoreId() uint32

type RequestMetadata

+ SpendLimits []*SpendLimit

+ func (x *RequestMetadata) GetSpendLimits() []*SpendLimit

+ type SpendLimit struct

+ Limit string

+ SpendType string

+ func (*SpendLimit) Descriptor() ([]byte, []int)

+ func (*SpendLimit) ProtoMessage()

+ func (x *SpendLimit) GetLimit() string

+ func (x *SpendLimit) GetSpendType() string

+ func (x *SpendLimit) ProtoReflect() protoreflect.Message

+ func (x *SpendLimit) Reset()

+ func (x *SpendLimit) String() string

type TriggerEvent

+ Payload *anypb.Any

+ func (x *TriggerEvent) GetPayload() *anypb.Any

type TriggerRegistrationRequest

+ Method string

+ Payload *anypb.Any

+ func (x *TriggerRegistrationRequest) GetMethod() string

+ func (x *TriggerRegistrationRequest) GetPayload() *anypb.Any

v0.7.1-ccip

Aug 7, 2025

v0.7.0

Apr 14, 2025

v0.6.0

Mar 27, 2025

Changes in this version

type CapabilityResponse

+ Metadata *ResponseMetadata

+ func (x *CapabilityResponse) GetMetadata() *ResponseMetadata

+ type MeteringReport struct

+ Steps map[string]*MeteringReportStep

+ func (*MeteringReport) Descriptor() ([]byte, []int)

+ func (*MeteringReport) ProtoMessage()

+ func (x *MeteringReport) GetSteps() map[string]*MeteringReportStep

+ func (x *MeteringReport) ProtoReflect() protoreflect.Message

+ func (x *MeteringReport) Reset()

+ func (x *MeteringReport) String() string

+ type MeteringReportNodeDetail struct

+ Peer_2PeerId string

+ SpendUnit string

+ SpendValue string

+ func (*MeteringReportNodeDetail) Descriptor() ([]byte, []int)

+ func (*MeteringReportNodeDetail) ProtoMessage()

+ func (x *MeteringReportNodeDetail) GetPeer_2PeerId() string

+ func (x *MeteringReportNodeDetail) GetSpendUnit() string

+ func (x *MeteringReportNodeDetail) GetSpendValue() string

+ func (x *MeteringReportNodeDetail) ProtoReflect() protoreflect.Message

+ func (x *MeteringReportNodeDetail) Reset()

+ func (x *MeteringReportNodeDetail) String() string

+ type MeteringReportStep struct

+ Nodes []*MeteringReportNodeDetail

+ func (*MeteringReportStep) Descriptor() ([]byte, []int)

+ func (*MeteringReportStep) ProtoMessage()

+ func (x *MeteringReportStep) GetNodes() []*MeteringReportNodeDetail

+ func (x *MeteringReportStep) ProtoReflect() protoreflect.Message

+ func (x *MeteringReportStep) Reset()

+ func (x *MeteringReportStep) String() string

+ type ResponseMetadata struct

+ Metering []*MeteringReportNodeDetail

+ func (*ResponseMetadata) Descriptor() ([]byte, []int)

+ func (*ResponseMetadata) ProtoMessage()

+ func (x *ResponseMetadata) GetMetering() []*MeteringReportNodeDetail

+ func (x *ResponseMetadata) ProtoReflect() protoreflect.Message

+ func (x *ResponseMetadata) Reset()

+ func (x *ResponseMetadata) String() string

v0.5.0

Mar 12, 2025

Changes in this version

+ var File_capabilities_pb_triggers_proto protoreflect.FileDescriptor

type CapabilityConfig

+ RestrictedConfig *pb.Map

+ RestrictedKeys []string

+ func (x *CapabilityConfig) GetRestrictedConfig() *pb.Map

+ func (x *CapabilityConfig) GetRestrictedKeys() []string

+ type OCRAttributedOnchainSignature struct

+ Signature []byte

+ Signer uint32

+ func (*OCRAttributedOnchainSignature) Descriptor() ([]byte, []int)

+ func (*OCRAttributedOnchainSignature) ProtoMessage()

+ func (x *OCRAttributedOnchainSignature) GetSignature() []byte

+ func (x *OCRAttributedOnchainSignature) GetSigner() uint32

+ func (x *OCRAttributedOnchainSignature) ProtoReflect() protoreflect.Message

+ func (x *OCRAttributedOnchainSignature) Reset()

+ func (x *OCRAttributedOnchainSignature) String() string

+ type OCRTriggerEvent struct

+ ConfigDigest []byte

+ Report []byte

+ SeqNr uint64

+ Sigs []*OCRAttributedOnchainSignature

+ func (*OCRTriggerEvent) Descriptor() ([]byte, []int)

+ func (*OCRTriggerEvent) ProtoMessage()

+ func (x *OCRTriggerEvent) GetConfigDigest() []byte

+ func (x *OCRTriggerEvent) GetReport() []byte

+ func (x *OCRTriggerEvent) GetSeqNr() uint64

+ func (x *OCRTriggerEvent) GetSigs() []*OCRAttributedOnchainSignature

+ func (x *OCRTriggerEvent) ProtoReflect() protoreflect.Message

+ func (x *OCRTriggerEvent) Reset()

+ func (x *OCRTriggerEvent) String() string

+ type OCRTriggerReport struct

+ EventID string

+ Outputs *pb.Map

+ Timestamp uint64

+ func (*OCRTriggerReport) Descriptor() ([]byte, []int)

+ func (*OCRTriggerReport) ProtoMessage()

+ func (x *OCRTriggerReport) GetEventID() string

+ func (x *OCRTriggerReport) GetOutputs() *pb.Map

+ func (x *OCRTriggerReport) GetTimestamp() uint64

+ func (x *OCRTriggerReport) ProtoReflect() protoreflect.Message

+ func (x *OCRTriggerReport) Reset()

+ func (x *OCRTriggerReport) String() string

v0.4.1

Jan 16, 2025

Changes in this version

type RemoteExecutableConfig

+ RegistrationExpiry *durationpb.Duration

+ RegistrationRefresh *durationpb.Duration

+ func (x *RemoteExecutableConfig) GetRegistrationExpiry() *durationpb.Duration

+ func (x *RemoteExecutableConfig) GetRegistrationRefresh() *durationpb.Duration

type RequestMetadata

+ DecodedWorkflowName string

+ func (x *RequestMetadata) GetDecodedWorkflowName() string

v0.4.0

Dec 14, 2024

Changes in this version

+ func MarshalRegisterToWorkflowRequest(req capabilities.RegisterToWorkflowRequest) ([]byte, error)

+ func MarshalUnregisterFromWorkflowRequest(req capabilities.UnregisterFromWorkflowRequest) ([]byte, error)

+ func RegisterToWorkflowRequestFromProto(req *RegisterToWorkflowRequest) (capabilities.RegisterToWorkflowRequest, error)

+ func UnmarshalRegisterToWorkflowRequest(raw []byte) (capabilities.RegisterToWorkflowRequest, error)

+ func UnmarshalUnregisterFromWorkflowRequest(raw []byte) (capabilities.UnregisterFromWorkflowRequest, error)

+ func UnregisterFromWorkflowRequestFromProto(req *UnregisterFromWorkflowRequest) (capabilities.UnregisterFromWorkflowRequest, error)

type CapabilityConfig

+ func (x *CapabilityConfig) GetRemoteExecutableConfig() *RemoteExecutableConfig

+ type CapabilityConfig_RemoteExecutableConfig struct

+ RemoteExecutableConfig *RemoteExecutableConfig

type RegisterToWorkflowRequest

+ func RegisterToWorkflowRequestToProto(req capabilities.RegisterToWorkflowRequest) *RegisterToWorkflowRequest

type RegistrationMetadata

+ ReferenceId string

+ WorkflowOwner string

+ func (x *RegistrationMetadata) GetReferenceId() string

+ func (x *RegistrationMetadata) GetWorkflowOwner() string

+ type RemoteExecutableConfig struct

+ RequestHashExcludedAttributes []string

+ func (*RemoteExecutableConfig) Descriptor() ([]byte, []int)

+ func (*RemoteExecutableConfig) ProtoMessage()

+ func (x *RemoteExecutableConfig) GetRequestHashExcludedAttributes() []string

+ func (x *RemoteExecutableConfig) ProtoReflect() protoreflect.Message

+ func (x *RemoteExecutableConfig) Reset()

+ func (x *RemoteExecutableConfig) String() string

type UnregisterFromWorkflowRequest

+ func UnregisterFromWorkflowRequestToProto(req capabilities.UnregisterFromWorkflowRequest) *UnregisterFromWorkflowRequest

v0.3.1-beholder

Nov 21, 2024

v0.3.0

Oct 9, 2024

Changes in this version

type InitialiseRequest

+ OracleFactoryId uint32

+ func (x *InitialiseRequest) GetOracleFactoryId() uint32

v0.2.2

Sep 17, 2024

Changes in this version

+ const Executable_Execute_FullMethodName

+ const Executable_RegisterToWorkflow_FullMethodName

+ const Executable_UnregisterFromWorkflow_FullMethodName

+ var Executable_ServiceDesc = grpc.ServiceDesc

+ var File_capabilities_pb_registry_proto protoreflect.FileDescriptor

+ func MarshalTriggerRegistrationRequest(req capabilities.TriggerRegistrationRequest) ([]byte, error)

+ func MarshalTriggerResponse(resp capabilities.TriggerResponse) ([]byte, error)

+ func RegisterExecutableServer(s grpc.ServiceRegistrar, srv ExecutableServer)

+ func TriggerRegistrationRequestFromProto(req *TriggerRegistrationRequest) (capabilities.TriggerRegistrationRequest, error)

+ func TriggerResponseFromProto(resp *TriggerResponse) (capabilities.TriggerResponse, error)

+ func UnmarshalTriggerRegistrationRequest(raw []byte) (capabilities.TriggerRegistrationRequest, error)

+ func UnmarshalTriggerResponse(raw []byte) (capabilities.TriggerResponse, error)

+ type CapabilityConfig struct

+ DefaultConfig *pb.Map

+ RemoteConfig isCapabilityConfig_RemoteConfig

+ func (*CapabilityConfig) Descriptor() ([]byte, []int)

+ func (*CapabilityConfig) ProtoMessage()

+ func (m *CapabilityConfig) GetRemoteConfig() isCapabilityConfig_RemoteConfig

+ func (x *CapabilityConfig) GetDefaultConfig() *pb.Map

+ func (x *CapabilityConfig) GetRemoteTargetConfig() *RemoteTargetConfig

+ func (x *CapabilityConfig) GetRemoteTriggerConfig() *RemoteTriggerConfig

+ func (x *CapabilityConfig) ProtoReflect() protoreflect.Message

+ func (x *CapabilityConfig) Reset()

+ func (x *CapabilityConfig) String() string

+ type CapabilityConfig_RemoteTargetConfig struct

+ RemoteTargetConfig *RemoteTargetConfig

+ type CapabilityConfig_RemoteTriggerConfig struct

+ RemoteTriggerConfig *RemoteTriggerConfig

type CapabilityInfoReply

+ IsLocal bool

+ func (x *CapabilityInfoReply) GetIsLocal() bool

+ type ExecutableClient interface

+ Execute func(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (Executable_ExecuteClient, error)

+ RegisterToWorkflow func(ctx context.Context, in *RegisterToWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UnregisterFromWorkflow func(ctx context.Context, in *UnregisterFromWorkflowRequest, ...) (*emptypb.Empty, error)

+ func NewExecutableClient(cc grpc.ClientConnInterface) ExecutableClient

+ type ExecutableServer interface

+ Execute func(*CapabilityRequest, Executable_ExecuteServer) error

+ RegisterToWorkflow func(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)

+ UnregisterFromWorkflow func(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)

+ type Executable_ExecuteClient interface

+ Recv func() (*CapabilityResponse, error)

+ type Executable_ExecuteServer interface

+ Send func(*CapabilityResponse) error

+ type RemoteTargetConfig struct

+ RequestHashExcludedAttributes []string

+ func (*RemoteTargetConfig) Descriptor() ([]byte, []int)

+ func (*RemoteTargetConfig) ProtoMessage()

+ func (x *RemoteTargetConfig) GetRequestHashExcludedAttributes() []string

+ func (x *RemoteTargetConfig) ProtoReflect() protoreflect.Message

+ func (x *RemoteTargetConfig) Reset()

+ func (x *RemoteTargetConfig) String() string

+ type RemoteTriggerConfig struct

+ BatchCollectionPeriod *durationpb.Duration

+ MaxBatchSize uint32

+ MessageExpiry *durationpb.Duration

+ MinResponsesToAggregate uint32

+ RegistrationExpiry *durationpb.Duration

+ RegistrationRefresh *durationpb.Duration

+ func (*RemoteTriggerConfig) Descriptor() ([]byte, []int)

+ func (*RemoteTriggerConfig) ProtoMessage()

+ func (x *RemoteTriggerConfig) GetBatchCollectionPeriod() *durationpb.Duration

+ func (x *RemoteTriggerConfig) GetMaxBatchSize() uint32

+ func (x *RemoteTriggerConfig) GetMessageExpiry() *durationpb.Duration

+ func (x *RemoteTriggerConfig) GetMinResponsesToAggregate() uint32

+ func (x *RemoteTriggerConfig) GetRegistrationExpiry() *durationpb.Duration

+ func (x *RemoteTriggerConfig) GetRegistrationRefresh() *durationpb.Duration

+ func (x *RemoteTriggerConfig) ProtoReflect() protoreflect.Message

+ func (x *RemoteTriggerConfig) Reset()

+ func (x *RemoteTriggerConfig) String() string

type RequestMetadata

+ ReferenceId string

+ WorkflowDonConfigVersion uint32

+ func (x *RequestMetadata) GetReferenceId() string

+ func (x *RequestMetadata) GetWorkflowDonConfigVersion() uint32

+ type TriggerEvent struct

+ Id string

+ Outputs *pb.Map

+ TriggerType string

+ func (*TriggerEvent) Descriptor() ([]byte, []int)

+ func (*TriggerEvent) ProtoMessage()

+ func (x *TriggerEvent) GetId() string

+ func (x *TriggerEvent) GetOutputs() *pb.Map

+ func (x *TriggerEvent) GetTriggerType() string

+ func (x *TriggerEvent) ProtoReflect() protoreflect.Message

+ func (x *TriggerEvent) Reset()

+ func (x *TriggerEvent) String() string

+ type TriggerRegistrationRequest struct

+ Config *pb.Map

+ Metadata *RequestMetadata

+ TriggerId string

+ func TriggerRegistrationRequestToProto(req capabilities.TriggerRegistrationRequest) *TriggerRegistrationRequest

+ func (*TriggerRegistrationRequest) Descriptor() ([]byte, []int)

+ func (*TriggerRegistrationRequest) ProtoMessage()

+ func (x *TriggerRegistrationRequest) GetConfig() *pb.Map

+ func (x *TriggerRegistrationRequest) GetMetadata() *RequestMetadata

+ func (x *TriggerRegistrationRequest) GetTriggerId() string

+ func (x *TriggerRegistrationRequest) ProtoReflect() protoreflect.Message

+ func (x *TriggerRegistrationRequest) Reset()

+ func (x *TriggerRegistrationRequest) String() string

+ type TriggerResponse struct

+ Error string

+ Event *TriggerEvent

+ func TriggerResponseToProto(resp capabilities.TriggerResponse) *TriggerResponse

+ func (*TriggerResponse) Descriptor() ([]byte, []int)

+ func (*TriggerResponse) ProtoMessage()

+ func (x *TriggerResponse) GetError() string

+ func (x *TriggerResponse) GetEvent() *TriggerEvent

+ func (x *TriggerResponse) ProtoReflect() protoreflect.Message

+ func (x *TriggerResponse) Reset()

+ func (x *TriggerResponse) String() string

+ type TriggerResponseMessage struct

+ Message isTriggerResponseMessage_Message

+ func (*TriggerResponseMessage) Descriptor() ([]byte, []int)

+ func (*TriggerResponseMessage) ProtoMessage()

+ func (m *TriggerResponseMessage) GetMessage() isTriggerResponseMessage_Message

+ func (x *TriggerResponseMessage) GetAck() *emptypb.Empty

+ func (x *TriggerResponseMessage) GetResponse() *TriggerResponse

+ func (x *TriggerResponseMessage) ProtoReflect() protoreflect.Message

+ func (x *TriggerResponseMessage) Reset()

+ func (x *TriggerResponseMessage) String() string

+ type TriggerResponseMessage_Ack struct

+ Ack *emptypb.Empty

+ type TriggerResponseMessage_Response struct

+ Response *TriggerResponse

+ type UnimplementedExecutableServer struct

+ func (UnimplementedExecutableServer) Execute(*CapabilityRequest, Executable_ExecuteServer) error

+ func (UnimplementedExecutableServer) RegisterToWorkflow(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)

+ func (UnimplementedExecutableServer) UnregisterFromWorkflow(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)

+ type UnsafeExecutableServer interface

v0.2.1

Jul 18, 2024

v0.2.0

Jul 15, 2024

Changes in this version

+ const BaseCapability_Info_FullMethodName

+ const CallbackExecutable_Execute_FullMethodName

+ const CallbackExecutable_RegisterToWorkflow_FullMethodName

+ const CallbackExecutable_UnregisterFromWorkflow_FullMethodName

+ const CapabilityTypeAction

+ const CapabilityTypeConsensus

+ const CapabilityTypeTarget

+ const CapabilityTypeTrigger

+ const CapabilityTypeUnknown

+ const StandardCapabilities_Infos_FullMethodName

+ const StandardCapabilities_Initialise_FullMethodName

+ const TriggerExecutable_RegisterTrigger_FullMethodName

+ const TriggerExecutable_UnregisterTrigger_FullMethodName

+ var BaseCapability_ServiceDesc = grpc.ServiceDesc

+ var CallbackExecutable_ServiceDesc = grpc.ServiceDesc

+ var CapabilityType_name = map[int32]string

+ var CapabilityType_value = map[string]int32

+ var File_capabilities_pb_capabilities_proto protoreflect.FileDescriptor

+ var StandardCapabilities_ServiceDesc = grpc.ServiceDesc

+ var TriggerExecutable_ServiceDesc = grpc.ServiceDesc

+ func CapabilityRequestFromProto(pr *CapabilityRequest) capabilities.CapabilityRequest

+ func CapabilityResponseFromProto(pr *CapabilityResponse) capabilities.CapabilityResponse

+ func MarshalCapabilityRequest(req capabilities.CapabilityRequest) ([]byte, error)

+ func MarshalCapabilityResponse(resp capabilities.CapabilityResponse) ([]byte, error)

+ func RegisterBaseCapabilityServer(s grpc.ServiceRegistrar, srv BaseCapabilityServer)

+ func RegisterCallbackExecutableServer(s grpc.ServiceRegistrar, srv CallbackExecutableServer)

+ func RegisterStandardCapabilitiesServer(s grpc.ServiceRegistrar, srv StandardCapabilitiesServer)

+ func RegisterTriggerExecutableServer(s grpc.ServiceRegistrar, srv TriggerExecutableServer)

+ func UnmarshalCapabilityRequest(raw []byte) (capabilities.CapabilityRequest, error)

+ func UnmarshalCapabilityResponse(raw []byte) (capabilities.CapabilityResponse, error)

+ type BaseCapabilityClient interface

+ Info func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CapabilityInfoReply, error)

+ func NewBaseCapabilityClient(cc grpc.ClientConnInterface) BaseCapabilityClient

+ type BaseCapabilityServer interface

+ Info func(context.Context, *emptypb.Empty) (*CapabilityInfoReply, error)

+ type CallbackExecutableClient interface

+ Execute func(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (CallbackExecutable_ExecuteClient, error)

+ RegisterToWorkflow func(ctx context.Context, in *RegisterToWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UnregisterFromWorkflow func(ctx context.Context, in *UnregisterFromWorkflowRequest, ...) (*emptypb.Empty, error)

+ func NewCallbackExecutableClient(cc grpc.ClientConnInterface) CallbackExecutableClient

+ type CallbackExecutableServer interface

+ Execute func(*CapabilityRequest, CallbackExecutable_ExecuteServer) error

+ RegisterToWorkflow func(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)

+ UnregisterFromWorkflow func(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)

+ type CallbackExecutable_ExecuteClient interface

+ Recv func() (*ResponseMessage, error)

+ type CallbackExecutable_ExecuteServer interface

+ Send func(*ResponseMessage) error

+ type CapabilityInfoReply struct

+ CapabilityType CapabilityType

+ Description string

+ Id string

+ Version string

+ func (*CapabilityInfoReply) Descriptor() ([]byte, []int)

+ func (*CapabilityInfoReply) ProtoMessage()

+ func (x *CapabilityInfoReply) GetCapabilityType() CapabilityType

+ func (x *CapabilityInfoReply) GetDescription() string

+ func (x *CapabilityInfoReply) GetId() string

+ func (x *CapabilityInfoReply) GetVersion() string

+ func (x *CapabilityInfoReply) ProtoReflect() protoreflect.Message

+ func (x *CapabilityInfoReply) Reset()

+ func (x *CapabilityInfoReply) String() string

+ type CapabilityInfosReply struct

+ Infos []*CapabilityInfoReply

+ func (*CapabilityInfosReply) Descriptor() ([]byte, []int)

+ func (*CapabilityInfosReply) ProtoMessage()

+ func (x *CapabilityInfosReply) GetInfos() []*CapabilityInfoReply

+ func (x *CapabilityInfosReply) ProtoReflect() protoreflect.Message

+ func (x *CapabilityInfosReply) Reset()

+ func (x *CapabilityInfosReply) String() string

+ type CapabilityRequest struct

+ Config *pb.Value

+ Inputs *pb.Value

+ Metadata *RequestMetadata

+ func CapabilityRequestToProto(req capabilities.CapabilityRequest) *CapabilityRequest

+ func (*CapabilityRequest) Descriptor() ([]byte, []int)

+ func (*CapabilityRequest) ProtoMessage()

+ func (x *CapabilityRequest) GetConfig() *pb.Value

+ func (x *CapabilityRequest) GetInputs() *pb.Value

+ func (x *CapabilityRequest) GetMetadata() *RequestMetadata

+ func (x *CapabilityRequest) ProtoReflect() protoreflect.Message

+ func (x *CapabilityRequest) Reset()

+ func (x *CapabilityRequest) String() string

+ type CapabilityResponse struct

+ Error string

+ Value *pb.Value

+ func CapabilityResponseToProto(resp capabilities.CapabilityResponse) *CapabilityResponse

+ func (*CapabilityResponse) Descriptor() ([]byte, []int)

+ func (*CapabilityResponse) ProtoMessage()

+ func (x *CapabilityResponse) GetError() string

+ func (x *CapabilityResponse) GetValue() *pb.Value

+ func (x *CapabilityResponse) ProtoReflect() protoreflect.Message

+ func (x *CapabilityResponse) Reset()

+ func (x *CapabilityResponse) String() string

+ type CapabilityType int32

+ const CapabilityType_CAPABILITY_TYPE_ACTION

+ const CapabilityType_CAPABILITY_TYPE_CONSENSUS

+ const CapabilityType_CAPABILITY_TYPE_TARGET

+ const CapabilityType_CAPABILITY_TYPE_TRIGGER

+ const CapabilityType_CAPABILITY_TYPE_UNKNOWN

+ func (CapabilityType) Descriptor() protoreflect.EnumDescriptor

+ func (CapabilityType) EnumDescriptor() ([]byte, []int)

+ func (CapabilityType) Type() protoreflect.EnumType

+ func (x CapabilityType) Enum() *CapabilityType

+ func (x CapabilityType) Number() protoreflect.EnumNumber

+ func (x CapabilityType) String() string

+ type InitialiseRequest struct

+ CapRegistryId uint32

+ Config string

+ ErrorLogId uint32

+ KeyValueStoreId uint32

+ PipelineRunnerId uint32

+ RelayerSetId uint32

+ TelemetryId uint32

+ func (*InitialiseRequest) Descriptor() ([]byte, []int)

+ func (*InitialiseRequest) ProtoMessage()

+ func (x *InitialiseRequest) GetCapRegistryId() uint32

+ func (x *InitialiseRequest) GetConfig() string

+ func (x *InitialiseRequest) GetErrorLogId() uint32

+ func (x *InitialiseRequest) GetKeyValueStoreId() uint32

+ func (x *InitialiseRequest) GetPipelineRunnerId() uint32

+ func (x *InitialiseRequest) GetRelayerSetId() uint32

+ func (x *InitialiseRequest) GetTelemetryId() uint32

+ func (x *InitialiseRequest) ProtoReflect() protoreflect.Message

+ func (x *InitialiseRequest) Reset()

+ func (x *InitialiseRequest) String() string

+ type RegisterToWorkflowRequest struct

+ Config *pb.Value

+ Metadata *RegistrationMetadata

+ func (*RegisterToWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*RegisterToWorkflowRequest) ProtoMessage()

+ func (x *RegisterToWorkflowRequest) GetConfig() *pb.Value

+ func (x *RegisterToWorkflowRequest) GetMetadata() *RegistrationMetadata

+ func (x *RegisterToWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *RegisterToWorkflowRequest) Reset()

+ func (x *RegisterToWorkflowRequest) String() string

+ type RegistrationMetadata struct

+ WorkflowId string

+ func (*RegistrationMetadata) Descriptor() ([]byte, []int)

+ func (*RegistrationMetadata) ProtoMessage()

+ func (x *RegistrationMetadata) GetWorkflowId() string

+ func (x *RegistrationMetadata) ProtoReflect() protoreflect.Message

+ func (x *RegistrationMetadata) Reset()

+ func (x *RegistrationMetadata) String() string

+ type RequestMetadata struct

+ WorkflowDonId uint32

+ WorkflowExecutionId string

+ WorkflowId string

+ WorkflowName string

+ WorkflowOwner string

+ func (*RequestMetadata) Descriptor() ([]byte, []int)

+ func (*RequestMetadata) ProtoMessage()

+ func (x *RequestMetadata) GetWorkflowDonId() uint32

+ func (x *RequestMetadata) GetWorkflowExecutionId() string

+ func (x *RequestMetadata) GetWorkflowId() string

+ func (x *RequestMetadata) GetWorkflowName() string

+ func (x *RequestMetadata) GetWorkflowOwner() string

+ func (x *RequestMetadata) ProtoReflect() protoreflect.Message

+ func (x *RequestMetadata) Reset()

+ func (x *RequestMetadata) String() string

+ type ResponseMessage struct

+ Message isResponseMessage_Message

+ func (*ResponseMessage) Descriptor() ([]byte, []int)

+ func (*ResponseMessage) ProtoMessage()

+ func (m *ResponseMessage) GetMessage() isResponseMessage_Message

+ func (x *ResponseMessage) GetAck() *emptypb.Empty

+ func (x *ResponseMessage) GetResponse() *CapabilityResponse

+ func (x *ResponseMessage) ProtoReflect() protoreflect.Message

+ func (x *ResponseMessage) Reset()

+ func (x *ResponseMessage) String() string

+ type ResponseMessage_Ack struct

+ Ack *emptypb.Empty

+ type ResponseMessage_Response struct

+ Response *CapabilityResponse

+ type StandardCapabilitiesClient interface

+ Infos func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CapabilityInfosReply, error)

+ Initialise func(ctx context.Context, in *InitialiseRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewStandardCapabilitiesClient(cc grpc.ClientConnInterface) StandardCapabilitiesClient

+ type StandardCapabilitiesServer interface

+ Infos func(context.Context, *emptypb.Empty) (*CapabilityInfosReply, error)

+ Initialise func(context.Context, *InitialiseRequest) (*emptypb.Empty, error)

+ type TriggerExecutableClient interface

+ RegisterTrigger func(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (TriggerExecutable_RegisterTriggerClient, error)

+ UnregisterTrigger func(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewTriggerExecutableClient(cc grpc.ClientConnInterface) TriggerExecutableClient

+ type TriggerExecutableServer interface

+ RegisterTrigger func(*CapabilityRequest, TriggerExecutable_RegisterTriggerServer) error

+ UnregisterTrigger func(context.Context, *CapabilityRequest) (*emptypb.Empty, error)

+ type TriggerExecutable_RegisterTriggerClient interface

+ Recv func() (*ResponseMessage, error)

+ type TriggerExecutable_RegisterTriggerServer interface

+ Send func(*ResponseMessage) error

+ type UnimplementedBaseCapabilityServer struct

+ func (UnimplementedBaseCapabilityServer) Info(context.Context, *emptypb.Empty) (*CapabilityInfoReply, error)

+ type UnimplementedCallbackExecutableServer struct

+ func (UnimplementedCallbackExecutableServer) Execute(*CapabilityRequest, CallbackExecutable_ExecuteServer) error

+ func (UnimplementedCallbackExecutableServer) RegisterToWorkflow(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)

+ func (UnimplementedCallbackExecutableServer) UnregisterFromWorkflow(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)

+ type UnimplementedStandardCapabilitiesServer struct

+ func (UnimplementedStandardCapabilitiesServer) Infos(context.Context, *emptypb.Empty) (*CapabilityInfosReply, error)

+ func (UnimplementedStandardCapabilitiesServer) Initialise(context.Context, *InitialiseRequest) (*emptypb.Empty, error)

+ type UnimplementedTriggerExecutableServer struct

+ func (UnimplementedTriggerExecutableServer) RegisterTrigger(*CapabilityRequest, TriggerExecutable_RegisterTriggerServer) error

+ func (UnimplementedTriggerExecutableServer) UnregisterTrigger(context.Context, *CapabilityRequest) (*emptypb.Empty, error)

+ type UnregisterFromWorkflowRequest struct

+ Config *pb.Value

+ Metadata *RegistrationMetadata

+ func (*UnregisterFromWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*UnregisterFromWorkflowRequest) ProtoMessage()

+ func (x *UnregisterFromWorkflowRequest) GetConfig() *pb.Value

+ func (x *UnregisterFromWorkflowRequest) GetMetadata() *RegistrationMetadata

+ func (x *UnregisterFromWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *UnregisterFromWorkflowRequest) Reset()

+ func (x *UnregisterFromWorkflowRequest) String() string

+ type UnsafeBaseCapabilityServer interface

+ type UnsafeCallbackExecutableServer interface

+ type UnsafeStandardCapabilitiesServer interface

+ type UnsafeTriggerExecutableServer interface

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