pb

type AggregatorConfig struct {
	AggregatorType AggregatorType `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AggregatorType int32

type BaseCapabilityClient interface {
	Info(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CapabilityInfoReply, error)
}

type BaseCapabilityServer interface {
	Info(context.Context, *emptypb.Empty) (*CapabilityInfoReply, error)
	// contains filtered or unexported methods
}

type CapabilityConfig struct {
	DefaultConfig *pb.Map `protobuf:"bytes,1,opt,name=default_config,json=defaultConfig,proto3" json:"default_config,omitempty"`
	// Types that are valid to be assigned to RemoteConfig:
	//
	//	*CapabilityConfig_RemoteTriggerConfig
	//	*CapabilityConfig_RemoteTargetConfig
	//	*CapabilityConfig_RemoteExecutableConfig
	RemoteConfig     isCapabilityConfig_RemoteConfig `protobuf_oneof:"remote_config"`
	RestrictedConfig *pb.Map                         `protobuf:"bytes,5,opt,name=restricted_config,json=restrictedConfig,proto3" json:"restricted_config,omitempty"`
	RestrictedKeys   []string                        `protobuf:"bytes,6,rep,name=restricted_keys,json=restrictedKeys,proto3" json:"restricted_keys,omitempty"`
	// v2 ("NoDAG") capabilities
	MethodConfigs map[string]*CapabilityMethodConfig `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CapabilityConfig_RemoteExecutableConfig struct {
	RemoteExecutableConfig *RemoteExecutableConfig `protobuf:"bytes,4,opt,name=remote_executable_config,json=remoteExecutableConfig,proto3,oneof"`
}

type CapabilityConfig_RemoteTargetConfig struct {
	RemoteTargetConfig *RemoteTargetConfig `protobuf:"bytes,3,opt,name=remote_target_config,json=remoteTargetConfig,proto3,oneof"`
}

type CapabilityConfig_RemoteTriggerConfig struct {
	RemoteTriggerConfig *RemoteTriggerConfig `protobuf:"bytes,2,opt,name=remote_trigger_config,json=remoteTriggerConfig,proto3,oneof"`
}

type CapabilityInfoReply struct {
	Id             string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CapabilityType CapabilityType `` /* 137-byte string literal not displayed */
	Description    string         `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Version        string         `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	IsLocal        bool           `protobuf:"varint,5,opt,name=isLocal,proto3" json:"isLocal,omitempty"`
	SpendTypes     []string       `protobuf:"bytes,6,rep,name=spend_types,json=spendTypes,proto3" json:"spend_types,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityInfosReply struct {
	Infos []*CapabilityInfoReply `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityMethodConfig struct {

	// Types that are valid to be assigned to RemoteConfig:
	//
	//	*CapabilityMethodConfig_RemoteTriggerConfig
	//	*CapabilityMethodConfig_RemoteExecutableConfig
	RemoteConfig     isCapabilityMethodConfig_RemoteConfig `protobuf_oneof:"remote_config"`
	AggregatorConfig *AggregatorConfig                     `protobuf:"bytes,3,opt,name=aggregator_config,json=aggregatorConfig,proto3" json:"aggregator_config,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityMethodConfig_RemoteExecutableConfig struct {
	RemoteExecutableConfig *RemoteExecutableConfig `protobuf:"bytes,2,opt,name=remote_executable_config,json=remoteExecutableConfig,proto3,oneof"`
}

type CapabilityMethodConfig_RemoteTriggerConfig struct {
	RemoteTriggerConfig *RemoteTriggerConfig `protobuf:"bytes,1,opt,name=remote_trigger_config,json=remoteTriggerConfig,proto3,oneof"`
}

type CapabilityRequest struct {
	Metadata *RequestMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Used for DAG SDK
	Config *pb.Map `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Used for DAG SDK
	Inputs *pb.Map `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Used for no DAG SDK
	Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Used for no DAG SDK
	ConfigPayload *anypb.Any `protobuf:"bytes,5,opt,name=configPayload,proto3" json:"configPayload,omitempty"`
	// Used for no DAG SDK
	Method       string `protobuf:"bytes,6,opt,name=method,proto3" json:"method,omitempty"`
	CapabilityId string `protobuf:"bytes,7,opt,name=capabilityId,proto3" json:"capabilityId,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityResponse struct {

	// Used for DAG SDK
	Value    *pb.Map           `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Error    string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Metadata *ResponseMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Used for no DAG SDK
	Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityType int32

type ExecutableClient interface {
	RegisterToWorkflow(ctx context.Context, in *RegisterToWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UnregisterFromWorkflow(ctx context.Context, in *UnregisterFromWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Execute(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CapabilityResponse], error)
}

type ExecutableServer interface {
	RegisterToWorkflow(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)
	UnregisterFromWorkflow(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)
	Execute(*CapabilityRequest, grpc.ServerStreamingServer[CapabilityResponse]) error
	// contains filtered or unexported methods
}

type Executable_ExecuteClient = grpc.ServerStreamingClient[CapabilityResponse]

type Executable_ExecuteServer = grpc.ServerStreamingServer[CapabilityResponse]

type InitialiseRequest struct {
	Config             string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	ErrorLogId         uint32 `protobuf:"varint,2,opt,name=error_log_id,json=errorLogId,proto3" json:"error_log_id,omitempty"`
	PipelineRunnerId   uint32 `protobuf:"varint,3,opt,name=pipeline_runner_id,json=pipelineRunnerId,proto3" json:"pipeline_runner_id,omitempty"`
	TelemetryId        uint32 `protobuf:"varint,4,opt,name=telemetry_id,json=telemetryId,proto3" json:"telemetry_id,omitempty"`
	CapRegistryId      uint32 `protobuf:"varint,5,opt,name=capRegistry_id,json=capRegistryId,proto3" json:"capRegistry_id,omitempty"`
	KeyValueStoreId    uint32 `protobuf:"varint,6,opt,name=keyValueStore_id,json=keyValueStoreId,proto3" json:"keyValueStore_id,omitempty"`
	RelayerSetId       uint32 `protobuf:"varint,7,opt,name=relayer_set_id,json=relayerSetId,proto3" json:"relayer_set_id,omitempty"`
	OracleFactoryId    uint32 `protobuf:"varint,8,opt,name=oracle_factory_id,json=oracleFactoryId,proto3" json:"oracle_factory_id,omitempty"`
	GatewayConnectorId uint32 `protobuf:"varint,9,opt,name=gateway_connector_id,json=gatewayConnectorId,proto3" json:"gateway_connector_id,omitempty"`
	KeystoreId         uint32 `protobuf:"varint,10,opt,name=keystore_id,json=keystoreId,proto3" json:"keystore_id,omitempty"`
	// contains filtered or unexported fields
}

type OCRAttributedOnchainSignature struct {
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	// signer is actually a uint8 but uint32 is the smallest supported by protobuf
	Signer uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"`
	// contains filtered or unexported fields
}

type OCRTriggerEvent struct {
	ConfigDigest []byte                           `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"`
	SeqNr        uint64                           `protobuf:"varint,2,opt,name=seqNr,proto3" json:"seqNr,omitempty"`
	Report       []byte                           `protobuf:"bytes,3,opt,name=report,proto3" json:"report,omitempty"` // marshalled OCRTriggerReport
	Sigs         []*OCRAttributedOnchainSignature `protobuf:"bytes,4,rep,name=sigs,proto3" json:"sigs,omitempty"`
	// contains filtered or unexported fields
}

type OCRTriggerReport struct {
	EventID   string  `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`      // unique, scoped to the trigger capability
	Timestamp uint64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // used to enforce freshness
	Outputs   *pb.Map `protobuf:"bytes,3,opt,name=outputs,proto3" json:"outputs,omitempty"`      // contains trigger-specific data
	// contains filtered or unexported fields
}

type RegisterToWorkflowRequest struct {
	Metadata *RegistrationMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   *pb.Map               `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type RegistrationMetadata struct {
	WorkflowId    string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	ReferenceId   string `protobuf:"bytes,2,opt,name=reference_id,json=referenceId,proto3" json:"reference_id,omitempty"`
	WorkflowOwner string `protobuf:"bytes,3,opt,name=workflow_owner,json=workflowOwner,proto3" json:"workflow_owner,omitempty"`
	// contains filtered or unexported fields
}

type RemoteExecutableConfig struct {

	// A collection of dot seperated paths to attributes that should be excluded from the request sent to the remote executable capability
	// when calculating the hash of the request.  This is useful for excluding attributes that are not deterministic to ensure
	// that the hash of logically identical requests is consistent.
	RequestHashExcludedAttributes []string             `protobuf:"bytes,1,rep,name=requestHashExcludedAttributes,proto3" json:"requestHashExcludedAttributes,omitempty"` // deprecated - v1 only
	TransmissionSchedule          TransmissionSchedule ``                                                                                                                /* 153-byte string literal not displayed */
	DeltaStage                    *durationpb.Duration `protobuf:"bytes,5,opt,name=delta_stage,json=deltaStage,proto3" json:"delta_stage,omitempty"`
	RequestTimeout                *durationpb.Duration `protobuf:"bytes,6,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"`
	ServerMaxParallelRequests     uint32               `` /* 141-byte string literal not displayed */
	RequestHasherType             RequestHasherType    `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RemoteTargetConfig struct {

	// A collection of dot seperated paths to attributes that should be excluded from the request sent to the remote target
	// when calculating the hash of the request.  This is useful for excluding attributes that are not deterministic to ensure
	// that the hash of logically identical requests is consistent.
	RequestHashExcludedAttributes []string `protobuf:"bytes,1,rep,name=requestHashExcludedAttributes,proto3" json:"requestHashExcludedAttributes,omitempty"`
	// contains filtered or unexported fields
}

type RemoteTriggerConfig struct {
	RegistrationRefresh     *durationpb.Duration `protobuf:"bytes,1,opt,name=registrationRefresh,proto3" json:"registrationRefresh,omitempty"`
	RegistrationExpiry      *durationpb.Duration `protobuf:"bytes,2,opt,name=registrationExpiry,proto3" json:"registrationExpiry,omitempty"`
	MinResponsesToAggregate uint32               `protobuf:"varint,3,opt,name=minResponsesToAggregate,proto3" json:"minResponsesToAggregate,omitempty"`
	MessageExpiry           *durationpb.Duration `protobuf:"bytes,4,opt,name=messageExpiry,proto3" json:"messageExpiry,omitempty"`
	MaxBatchSize            uint32               `protobuf:"varint,5,opt,name=maxBatchSize,proto3" json:"maxBatchSize,omitempty"`
	BatchCollectionPeriod   *durationpb.Duration `protobuf:"bytes,6,opt,name=batchCollectionPeriod,proto3" json:"batchCollectionPeriod,omitempty"`
	// contains filtered or unexported fields
}

type RequestHasherType int32

type RequestMetadata struct {
	WorkflowId               string        `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowExecutionId      string        `protobuf:"bytes,2,opt,name=workflow_execution_id,json=workflowExecutionId,proto3" json:"workflow_execution_id,omitempty"`
	WorkflowOwner            string        `protobuf:"bytes,3,opt,name=workflow_owner,json=workflowOwner,proto3" json:"workflow_owner,omitempty"`
	WorkflowName             string        `protobuf:"bytes,4,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	WorkflowDonId            uint32        `protobuf:"varint,6,opt,name=workflow_don_id,json=workflowDonId,proto3" json:"workflow_don_id,omitempty"`
	WorkflowDonConfigVersion uint32        `` /* 138-byte string literal not displayed */
	ReferenceId              string        `protobuf:"bytes,8,opt,name=reference_id,json=referenceId,proto3" json:"reference_id,omitempty"`
	DecodedWorkflowName      string        `protobuf:"bytes,9,opt,name=decoded_workflow_name,json=decodedWorkflowName,proto3" json:"decoded_workflow_name,omitempty"`
	SpendLimits              []*SpendLimit `protobuf:"bytes,10,rep,name=spend_limits,json=spendLimits,proto3" json:"spend_limits,omitempty"`
	WorkflowTag              string        `protobuf:"bytes,11,opt,name=workflow_tag,json=workflowTag,proto3" json:"workflow_tag,omitempty"`
	// contains filtered or unexported fields
}

type ResponseMetadata struct {

	// MeteringReportNodeDetail is repeated here due to
	// the identical response aggregation strategy at the Don2Don layer.
	// We expect identical responses from capabilities, but not identical
	// metering reports. Since we pass the CapabilityResponse through the
	// protocol layer to the engine, this field needs to be repeated to
	// eventually hold all the reports from each capability response node.
	//
	// If you are working with this in a capability, you should not emit
	// more than one metering report per node.
	Metering []*pb1.MeteringReportNodeDetail `protobuf:"bytes,1,rep,name=metering,proto3" json:"metering,omitempty"`
	// contains filtered or unexported fields
}

type SpendLimit struct {
	SpendType string `protobuf:"bytes,1,opt,name=spend_type,json=spendType,proto3" json:"spend_type,omitempty"`
	Limit     string `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type StandardCapabilitiesClient interface {
	Initialise(ctx context.Context, in *InitialiseRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Infos(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CapabilityInfosReply, error)
}

type StandardCapabilitiesServer interface {
	Initialise(context.Context, *InitialiseRequest) (*emptypb.Empty, error)
	Infos(context.Context, *emptypb.Empty) (*CapabilityInfosReply, error)
	// contains filtered or unexported methods
}

type TransmissionSchedule int32

type TriggerEvent struct {
	TriggerType string `protobuf:"bytes,1,opt,name=triggerType,proto3" json:"triggerType,omitempty"`
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Used for DAG SDK
	Outputs *pb.Map `protobuf:"bytes,4,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// used for no DAG SDK
	Payload *anypb.Any `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type TriggerExecutableClient interface {
	RegisterTrigger(ctx context.Context, in *TriggerRegistrationRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TriggerResponseMessage], error)
	UnregisterTrigger(ctx context.Context, in *TriggerRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type TriggerExecutableServer interface {
	RegisterTrigger(*TriggerRegistrationRequest, grpc.ServerStreamingServer[TriggerResponseMessage]) error
	UnregisterTrigger(context.Context, *TriggerRegistrationRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type TriggerExecutable_RegisterTriggerClient = grpc.ServerStreamingClient[TriggerResponseMessage]

type TriggerExecutable_RegisterTriggerServer = grpc.ServerStreamingServer[TriggerResponseMessage]

type TriggerRegistrationRequest struct {
	TriggerId string           `protobuf:"bytes,1,opt,name=triggerId,proto3" json:"triggerId,omitempty"`
	Metadata  *RequestMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Used for DAG SDK
	Config *pb.Map `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// Used for no DAG SDK
	Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Used for no DAG SDK
	Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

type TriggerResponse struct {
	Event *TriggerEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Error string        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type TriggerResponseMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*TriggerResponseMessage_Ack
	//	*TriggerResponseMessage_Response
	Message isTriggerResponseMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type TriggerResponseMessage_Ack struct {
	Ack *emptypb.Empty `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

type TriggerResponseMessage_Response struct {
	Response *TriggerResponse `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type UnimplementedBaseCapabilityServer struct{}

type UnimplementedExecutableServer struct{}

type UnimplementedStandardCapabilitiesServer struct{}

type UnimplementedTriggerExecutableServer struct{}

type UnregisterFromWorkflowRequest struct {
	Metadata *RegistrationMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   *pb.Map               `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type UnsafeBaseCapabilityServer interface {
	// contains filtered or unexported methods
}

type UnsafeExecutableServer interface {
	// contains filtered or unexported methods
}

type UnsafeStandardCapabilitiesServer interface {
	// contains filtered or unexported methods
}

type UnsafeTriggerExecutableServer interface {
	// contains filtered or unexported methods
}