pb

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 CallbackExecutableClient 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) (CallbackExecutable_ExecuteClient, error)
}

type CallbackExecutableServer interface {
	RegisterToWorkflow(context.Context, *RegisterToWorkflowRequest) (*emptypb.Empty, error)
	UnregisterFromWorkflow(context.Context, *UnregisterFromWorkflowRequest) (*emptypb.Empty, error)
	Execute(*CapabilityRequest, CallbackExecutable_ExecuteServer) error
	// contains filtered or unexported methods
}

type CallbackExecutable_ExecuteClient interface {
	Recv() (*ResponseMessage, error)
	grpc.ClientStream
}

type CallbackExecutable_ExecuteServer interface {
	Send(*ResponseMessage) error
	grpc.ServerStream
}

type CapabilityInfoReply struct {
	Id             string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CapabilityType CapabilityType `` /* 129-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"`
	// 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 CapabilityRequest struct {
	Metadata *RequestMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   *pb.Value        `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	Inputs   *pb.Value        `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityResponse struct {
	Value *pb.Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Error string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityType int32

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"`
	// contains filtered or unexported fields
}

type RegisterToWorkflowRequest struct {
	Metadata *RegistrationMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   *pb.Value             `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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type ResponseMessage struct {

	// Types that are assignable to Message:
	//
	//	*ResponseMessage_Ack
	//	*ResponseMessage_Response
	Message isResponseMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

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

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

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 TriggerExecutableClient interface {
	RegisterTrigger(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (TriggerExecutable_RegisterTriggerClient, error)
	UnregisterTrigger(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type TriggerExecutableServer interface {
	RegisterTrigger(*CapabilityRequest, TriggerExecutable_RegisterTriggerServer) error
	UnregisterTrigger(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type TriggerExecutable_RegisterTriggerClient interface {
	Recv() (*ResponseMessage, error)
	grpc.ClientStream
}

type TriggerExecutable_RegisterTriggerServer interface {
	Send(*ResponseMessage) error
	grpc.ServerStream
}

type UnimplementedBaseCapabilityServer struct {
}

type UnimplementedCallbackExecutableServer struct {
}

type UnimplementedStandardCapabilitiesServer struct {
}

type UnimplementedTriggerExecutableServer struct {
}

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

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

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

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

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