pb

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 9, 2024 License: MIT Imports: 16 Imported by: 8

Documentation

Index

Constants

View Source 
const (
	TriggerExecutable_RegisterTrigger_FullMethodName   = "/capabilities.TriggerExecutable/RegisterTrigger"
	TriggerExecutable_UnregisterTrigger_FullMethodName = "/capabilities.TriggerExecutable/UnregisterTrigger"
)
View Source 
const (
	Executable_RegisterToWorkflow_FullMethodName     = "/capabilities.Executable/RegisterToWorkflow"
	Executable_UnregisterFromWorkflow_FullMethodName = "/capabilities.Executable/UnregisterFromWorkflow"
	Executable_Execute_FullMethodName                = "/capabilities.Executable/Execute"
)
View Source 
const (
	StandardCapabilities_Initialise_FullMethodName = "/capabilities.StandardCapabilities/Initialise"
	StandardCapabilities_Infos_FullMethodName      = "/capabilities.StandardCapabilities/Infos"
)
View Source 
const (
	CapabilityTypeUnknown   = CapabilityType_CAPABILITY_TYPE_UNKNOWN
	CapabilityTypeTrigger   = CapabilityType_CAPABILITY_TYPE_TRIGGER
	CapabilityTypeAction    = CapabilityType_CAPABILITY_TYPE_ACTION
	CapabilityTypeConsensus = CapabilityType_CAPABILITY_TYPE_CONSENSUS
	CapabilityTypeTarget    = CapabilityType_CAPABILITY_TYPE_TARGET
)
View Source 
const (
	BaseCapability_Info_FullMethodName = "/capabilities.BaseCapability/Info"
)

Variables

View Source 
var (
	CapabilityType_name = map[int32]string{
		0: "CAPABILITY_TYPE_UNKNOWN",
		1: "CAPABILITY_TYPE_TRIGGER",
		2: "CAPABILITY_TYPE_ACTION",
		3: "CAPABILITY_TYPE_CONSENSUS",
		4: "CAPABILITY_TYPE_TARGET",
	}
	CapabilityType_value = map[string]int32{
		"CAPABILITY_TYPE_UNKNOWN":   0,
		"CAPABILITY_TYPE_TRIGGER":   1,
		"CAPABILITY_TYPE_ACTION":    2,
		"CAPABILITY_TYPE_CONSENSUS": 3,
		"CAPABILITY_TYPE_TARGET":    4,
	}
)

Enum value maps for CapabilityType.

View Source 
var BaseCapability_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "capabilities.BaseCapability",
	HandlerType: (*BaseCapabilityServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Info",
			Handler:    _BaseCapability_Info_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "capabilities/pb/capabilities.proto",
}

BaseCapability_ServiceDesc is the grpc.ServiceDesc for BaseCapability service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Executable_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "capabilities.Executable",
	HandlerType: (*ExecutableServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterToWorkflow",
			Handler:    _Executable_RegisterToWorkflow_Handler,
		},
		{
			MethodName: "UnregisterFromWorkflow",
			Handler:    _Executable_UnregisterFromWorkflow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _Executable_Execute_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "capabilities/pb/capabilities.proto",
}

Executable_ServiceDesc is the grpc.ServiceDesc for Executable service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_capabilities_pb_capabilities_proto protoreflect.FileDescriptor
View Source 
var File_capabilities_pb_registry_proto protoreflect.FileDescriptor
View Source 
var StandardCapabilities_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "capabilities.StandardCapabilities",
	HandlerType: (*StandardCapabilitiesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Initialise",
			Handler:    _StandardCapabilities_Initialise_Handler,
		},
		{
			MethodName: "Infos",
			Handler:    _StandardCapabilities_Infos_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "capabilities/pb/capabilities.proto",
}

StandardCapabilities_ServiceDesc is the grpc.ServiceDesc for StandardCapabilities service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TriggerExecutable_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "capabilities.TriggerExecutable",
	HandlerType: (*TriggerExecutableServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UnregisterTrigger",
			Handler:    _TriggerExecutable_UnregisterTrigger_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RegisterTrigger",
			Handler:       _TriggerExecutable_RegisterTrigger_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "capabilities/pb/capabilities.proto",
}

TriggerExecutable_ServiceDesc is the grpc.ServiceDesc for TriggerExecutable service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func CapabilityRequestFromProto 

func CapabilityRequestFromProto(pr *CapabilityRequest) (capabilities.CapabilityRequest, error)

func CapabilityResponseFromProto 

func CapabilityResponseFromProto(pr *CapabilityResponse) (capabilities.CapabilityResponse, error)

func MarshalCapabilityRequest 

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

func MarshalCapabilityResponse 

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

func MarshalTriggerRegistrationRequest added in v0.2.2 

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

func MarshalTriggerResponse added in v0.2.2 

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

func RegisterBaseCapabilityServer 

func RegisterBaseCapabilityServer(s grpc.ServiceRegistrar, srv BaseCapabilityServer)

func RegisterExecutableServer added in v0.2.2 

func RegisterExecutableServer(s grpc.ServiceRegistrar, srv ExecutableServer)

func RegisterStandardCapabilitiesServer 

func RegisterStandardCapabilitiesServer(s grpc.ServiceRegistrar, srv StandardCapabilitiesServer)

func RegisterTriggerExecutableServer 

func RegisterTriggerExecutableServer(s grpc.ServiceRegistrar, srv TriggerExecutableServer)

func TriggerRegistrationRequestFromProto added in v0.2.2 

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

func TriggerResponseFromProto added in v0.2.2 

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

func UnmarshalCapabilityRequest 

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

func UnmarshalCapabilityResponse 

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

func UnmarshalTriggerRegistrationRequest added in v0.2.2 

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

func UnmarshalTriggerResponse added in v0.2.2 

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

Types

type BaseCapabilityClient 

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

BaseCapabilityClient is the client API for BaseCapability service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBaseCapabilityClient 

func NewBaseCapabilityClient(cc grpc.ClientConnInterface) BaseCapabilityClient

type BaseCapabilityServer 

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

BaseCapabilityServer is the server API for BaseCapability service. All implementations must embed UnimplementedBaseCapabilityServer for forward compatibility

type CapabilityConfig added in v0.2.2 

type CapabilityConfig struct {
	DefaultConfig *pb.Map `protobuf:"bytes,1,opt,name=default_config,json=defaultConfig,proto3" json:"default_config,omitempty"`
	// Types that are assignable to RemoteConfig:
	//
	//	*CapabilityConfig_RemoteTriggerConfig
	//	*CapabilityConfig_RemoteTargetConfig
	RemoteConfig isCapabilityConfig_RemoteConfig `protobuf_oneof:"remote_config"`
	// contains filtered or unexported fields
}

func (*CapabilityConfig) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use CapabilityConfig.ProtoReflect.Descriptor instead.

func (*CapabilityConfig) GetDefaultConfig added in v0.2.2 

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

func (*CapabilityConfig) GetRemoteConfig added in v0.2.2 

func (m *CapabilityConfig) GetRemoteConfig() isCapabilityConfig_RemoteConfig

func (*CapabilityConfig) GetRemoteTargetConfig added in v0.2.2 

func (x *CapabilityConfig) GetRemoteTargetConfig() *RemoteTargetConfig

func (*CapabilityConfig) GetRemoteTriggerConfig added in v0.2.2 

func (x *CapabilityConfig) GetRemoteTriggerConfig() *RemoteTriggerConfig

func (*CapabilityConfig) ProtoMessage added in v0.2.2 

func (*CapabilityConfig) ProtoMessage()

func (*CapabilityConfig) ProtoReflect added in v0.2.2 

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

func (*CapabilityConfig) Reset added in v0.2.2 

func (x *CapabilityConfig) Reset()

func (*CapabilityConfig) String added in v0.2.2 

func (x *CapabilityConfig) String() string

type CapabilityConfig_RemoteTargetConfig added in v0.2.2 

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

type CapabilityConfig_RemoteTriggerConfig added in v0.2.2 

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

type CapabilityInfoReply 

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

func (*CapabilityInfoReply) Descriptor deprecated 

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

Deprecated: Use CapabilityInfoReply.ProtoReflect.Descriptor instead.

func (*CapabilityInfoReply) GetCapabilityType 

func (x *CapabilityInfoReply) GetCapabilityType() CapabilityType

func (*CapabilityInfoReply) GetDescription 

func (x *CapabilityInfoReply) GetDescription() string

func (*CapabilityInfoReply) GetId 

func (x *CapabilityInfoReply) GetId() string

func (*CapabilityInfoReply) GetIsLocal added in v0.2.2 

func (x *CapabilityInfoReply) GetIsLocal() bool

func (*CapabilityInfoReply) GetVersion 

func (x *CapabilityInfoReply) GetVersion() string

func (*CapabilityInfoReply) ProtoMessage 

func (*CapabilityInfoReply) ProtoMessage()

func (*CapabilityInfoReply) ProtoReflect 

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

func (*CapabilityInfoReply) Reset 

func (x *CapabilityInfoReply) Reset()

func (*CapabilityInfoReply) String 

func (x *CapabilityInfoReply) String() string

type CapabilityInfosReply 

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

func (*CapabilityInfosReply) Descriptor deprecated 

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

Deprecated: Use CapabilityInfosReply.ProtoReflect.Descriptor instead.

func (*CapabilityInfosReply) GetInfos 

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

func (*CapabilityInfosReply) ProtoMessage 

func (*CapabilityInfosReply) ProtoMessage()

func (*CapabilityInfosReply) ProtoReflect 

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

func (*CapabilityInfosReply) Reset 

func (x *CapabilityInfosReply) Reset()

func (*CapabilityInfosReply) String 

func (x *CapabilityInfosReply) String() string

type CapabilityRequest 

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

func CapabilityRequestToProto 

func CapabilityRequestToProto(req capabilities.CapabilityRequest) *CapabilityRequest

func (*CapabilityRequest) Descriptor deprecated 

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

Deprecated: Use CapabilityRequest.ProtoReflect.Descriptor instead.

func (*CapabilityRequest) GetConfig 

func (x *CapabilityRequest) GetConfig() *pb.Map

func (*CapabilityRequest) GetInputs 

func (x *CapabilityRequest) GetInputs() *pb.Map

func (*CapabilityRequest) GetMetadata 

func (x *CapabilityRequest) GetMetadata() *RequestMetadata

func (*CapabilityRequest) ProtoMessage 

func (*CapabilityRequest) ProtoMessage()

func (*CapabilityRequest) ProtoReflect 

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

func (*CapabilityRequest) Reset 

func (x *CapabilityRequest) Reset()

func (*CapabilityRequest) String 

func (x *CapabilityRequest) String() string

type CapabilityResponse 

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

func CapabilityResponseToProto 

func CapabilityResponseToProto(resp capabilities.CapabilityResponse) *CapabilityResponse

func (*CapabilityResponse) Descriptor deprecated 

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

Deprecated: Use CapabilityResponse.ProtoReflect.Descriptor instead.

func (*CapabilityResponse) GetError 

func (x *CapabilityResponse) GetError() string

func (*CapabilityResponse) GetValue 

func (x *CapabilityResponse) GetValue() *pb.Map

func (*CapabilityResponse) ProtoMessage 

func (*CapabilityResponse) ProtoMessage()

func (*CapabilityResponse) ProtoReflect 

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

func (*CapabilityResponse) Reset 

func (x *CapabilityResponse) Reset()

func (*CapabilityResponse) String 

func (x *CapabilityResponse) String() string

type CapabilityType 

type CapabilityType int32
const (
	CapabilityType_CAPABILITY_TYPE_UNKNOWN   CapabilityType = 0
	CapabilityType_CAPABILITY_TYPE_TRIGGER   CapabilityType = 1
	CapabilityType_CAPABILITY_TYPE_ACTION    CapabilityType = 2
	CapabilityType_CAPABILITY_TYPE_CONSENSUS CapabilityType = 3
	CapabilityType_CAPABILITY_TYPE_TARGET    CapabilityType = 4
)

func (CapabilityType) Descriptor 

func (CapabilityType) Descriptor() protoreflect.EnumDescriptor

func (CapabilityType) Enum 

func (x CapabilityType) Enum() *CapabilityType

func (CapabilityType) EnumDescriptor deprecated 

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

Deprecated: Use CapabilityType.Descriptor instead.

func (CapabilityType) Number 

func (x CapabilityType) Number() protoreflect.EnumNumber

func (CapabilityType) String 

func (x CapabilityType) String() string

func (CapabilityType) Type 

func (CapabilityType) Type() protoreflect.EnumType

type ExecutableClient added in v0.2.2 

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

ExecutableClient is the client API for Executable service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutableClient added in v0.2.2 

func NewExecutableClient(cc grpc.ClientConnInterface) ExecutableClient

type ExecutableServer added in v0.2.2 

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

ExecutableServer is the server API for Executable service. All implementations must embed UnimplementedExecutableServer for forward compatibility

type Executable_ExecuteClient added in v0.2.2 

type Executable_ExecuteClient interface {
	Recv() (*CapabilityResponse, error)
	grpc.ClientStream
}

type Executable_ExecuteServer added in v0.2.2 

type Executable_ExecuteServer interface {
	Send(*CapabilityResponse) error
	grpc.ServerStream
}

type InitialiseRequest 

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

func (*InitialiseRequest) Descriptor deprecated 

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

Deprecated: Use InitialiseRequest.ProtoReflect.Descriptor instead.

func (*InitialiseRequest) GetCapRegistryId 

func (x *InitialiseRequest) GetCapRegistryId() uint32

func (*InitialiseRequest) GetConfig 

func (x *InitialiseRequest) GetConfig() string

func (*InitialiseRequest) GetErrorLogId 

func (x *InitialiseRequest) GetErrorLogId() uint32

func (*InitialiseRequest) GetKeyValueStoreId 

func (x *InitialiseRequest) GetKeyValueStoreId() uint32

func (*InitialiseRequest) GetOracleFactoryId added in v0.3.0 

func (x *InitialiseRequest) GetOracleFactoryId() uint32

func (*InitialiseRequest) GetPipelineRunnerId 

func (x *InitialiseRequest) GetPipelineRunnerId() uint32

func (*InitialiseRequest) GetRelayerSetId 

func (x *InitialiseRequest) GetRelayerSetId() uint32

func (*InitialiseRequest) GetTelemetryId 

func (x *InitialiseRequest) GetTelemetryId() uint32

func (*InitialiseRequest) ProtoMessage 

func (*InitialiseRequest) ProtoMessage()

func (*InitialiseRequest) ProtoReflect 

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

func (*InitialiseRequest) Reset 

func (x *InitialiseRequest) Reset()

func (*InitialiseRequest) String 

func (x *InitialiseRequest) String() string

type RegisterToWorkflowRequest 

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
}

func (*RegisterToWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use RegisterToWorkflowRequest.ProtoReflect.Descriptor instead.

func (*RegisterToWorkflowRequest) GetConfig 

func (x *RegisterToWorkflowRequest) GetConfig() *pb.Map

func (*RegisterToWorkflowRequest) GetMetadata 

func (x *RegisterToWorkflowRequest) GetMetadata() *RegistrationMetadata

func (*RegisterToWorkflowRequest) ProtoMessage 

func (*RegisterToWorkflowRequest) ProtoMessage()

func (*RegisterToWorkflowRequest) ProtoReflect 

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

func (*RegisterToWorkflowRequest) Reset 

func (x *RegisterToWorkflowRequest) Reset()

func (*RegisterToWorkflowRequest) String 

func (x *RegisterToWorkflowRequest) String() string

type RegistrationMetadata 

type RegistrationMetadata struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationMetadata) Descriptor deprecated 

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

Deprecated: Use RegistrationMetadata.ProtoReflect.Descriptor instead.

func (*RegistrationMetadata) GetWorkflowId 

func (x *RegistrationMetadata) GetWorkflowId() string

func (*RegistrationMetadata) ProtoMessage 

func (*RegistrationMetadata) ProtoMessage()

func (*RegistrationMetadata) ProtoReflect 

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

func (*RegistrationMetadata) Reset 

func (x *RegistrationMetadata) Reset()

func (*RegistrationMetadata) String 

func (x *RegistrationMetadata) String() string

type RemoteTargetConfig added in v0.2.2 

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
}

func (*RemoteTargetConfig) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use RemoteTargetConfig.ProtoReflect.Descriptor instead.

func (*RemoteTargetConfig) GetRequestHashExcludedAttributes added in v0.2.2 

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

func (*RemoteTargetConfig) ProtoMessage added in v0.2.2 

func (*RemoteTargetConfig) ProtoMessage()

func (*RemoteTargetConfig) ProtoReflect added in v0.2.2 

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

func (*RemoteTargetConfig) Reset added in v0.2.2 

func (x *RemoteTargetConfig) Reset()

func (*RemoteTargetConfig) String added in v0.2.2 

func (x *RemoteTargetConfig) String() string

type RemoteTriggerConfig added in v0.2.2 

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
}

func (*RemoteTriggerConfig) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use RemoteTriggerConfig.ProtoReflect.Descriptor instead.

func (*RemoteTriggerConfig) GetBatchCollectionPeriod added in v0.2.2 

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

func (*RemoteTriggerConfig) GetMaxBatchSize added in v0.2.2 

func (x *RemoteTriggerConfig) GetMaxBatchSize() uint32

func (*RemoteTriggerConfig) GetMessageExpiry added in v0.2.2 

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

func (*RemoteTriggerConfig) GetMinResponsesToAggregate added in v0.2.2 

func (x *RemoteTriggerConfig) GetMinResponsesToAggregate() uint32

func (*RemoteTriggerConfig) GetRegistrationExpiry added in v0.2.2 

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

func (*RemoteTriggerConfig) GetRegistrationRefresh added in v0.2.2 

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

func (*RemoteTriggerConfig) ProtoMessage added in v0.2.2 

func (*RemoteTriggerConfig) ProtoMessage()

func (*RemoteTriggerConfig) ProtoReflect added in v0.2.2 

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

func (*RemoteTriggerConfig) Reset added in v0.2.2 

func (x *RemoteTriggerConfig) Reset()

func (*RemoteTriggerConfig) String added in v0.2.2 

func (x *RemoteTriggerConfig) String() string

type RequestMetadata 

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

func (*RequestMetadata) Descriptor deprecated 

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

Deprecated: Use RequestMetadata.ProtoReflect.Descriptor instead.

func (*RequestMetadata) GetReferenceId added in v0.2.2 

func (x *RequestMetadata) GetReferenceId() string

func (*RequestMetadata) GetWorkflowDonConfigVersion added in v0.2.2 

func (x *RequestMetadata) GetWorkflowDonConfigVersion() uint32

func (*RequestMetadata) GetWorkflowDonId 

func (x *RequestMetadata) GetWorkflowDonId() uint32

func (*RequestMetadata) GetWorkflowExecutionId 

func (x *RequestMetadata) GetWorkflowExecutionId() string

func (*RequestMetadata) GetWorkflowId 

func (x *RequestMetadata) GetWorkflowId() string

func (*RequestMetadata) GetWorkflowName 

func (x *RequestMetadata) GetWorkflowName() string

func (*RequestMetadata) GetWorkflowOwner 

func (x *RequestMetadata) GetWorkflowOwner() string

func (*RequestMetadata) ProtoMessage 

func (*RequestMetadata) ProtoMessage()

func (*RequestMetadata) ProtoReflect 

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

func (*RequestMetadata) Reset 

func (x *RequestMetadata) Reset()

func (*RequestMetadata) String 

func (x *RequestMetadata) String() string

type StandardCapabilitiesClient 

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)
}

StandardCapabilitiesClient is the client API for StandardCapabilities service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStandardCapabilitiesClient 

func NewStandardCapabilitiesClient(cc grpc.ClientConnInterface) StandardCapabilitiesClient

type StandardCapabilitiesServer 

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

StandardCapabilitiesServer is the server API for StandardCapabilities service. All implementations must embed UnimplementedStandardCapabilitiesServer for forward compatibility

type TriggerEvent added in v0.2.2 

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"`
	Outputs     *pb.Map `protobuf:"bytes,4,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerEvent) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use TriggerEvent.ProtoReflect.Descriptor instead.

func (*TriggerEvent) GetId added in v0.2.2 

func (x *TriggerEvent) GetId() string

func (*TriggerEvent) GetOutputs added in v0.2.2 

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

func (*TriggerEvent) GetTriggerType added in v0.2.2 

func (x *TriggerEvent) GetTriggerType() string

func (*TriggerEvent) ProtoMessage added in v0.2.2 

func (*TriggerEvent) ProtoMessage()

func (*TriggerEvent) ProtoReflect added in v0.2.2 

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

func (*TriggerEvent) Reset added in v0.2.2 

func (x *TriggerEvent) Reset()

func (*TriggerEvent) String added in v0.2.2 

func (x *TriggerEvent) String() string

type TriggerExecutableClient 

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

TriggerExecutableClient is the client API for TriggerExecutable service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTriggerExecutableClient 

func NewTriggerExecutableClient(cc grpc.ClientConnInterface) TriggerExecutableClient

type TriggerExecutableServer 

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

TriggerExecutableServer is the server API for TriggerExecutable service. All implementations must embed UnimplementedTriggerExecutableServer for forward compatibility

type TriggerExecutable_RegisterTriggerClient 

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

type TriggerExecutable_RegisterTriggerServer 

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

type TriggerRegistrationRequest added in v0.2.2 

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"`
	Config    *pb.Map          `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func TriggerRegistrationRequestToProto added in v0.2.2 

func TriggerRegistrationRequestToProto(req capabilities.TriggerRegistrationRequest) *TriggerRegistrationRequest

func (*TriggerRegistrationRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use TriggerRegistrationRequest.ProtoReflect.Descriptor instead.

func (*TriggerRegistrationRequest) GetConfig added in v0.2.2 

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

func (*TriggerRegistrationRequest) GetMetadata added in v0.2.2 

func (x *TriggerRegistrationRequest) GetMetadata() *RequestMetadata

func (*TriggerRegistrationRequest) GetTriggerId added in v0.2.2 

func (x *TriggerRegistrationRequest) GetTriggerId() string

func (*TriggerRegistrationRequest) ProtoMessage added in v0.2.2 

func (*TriggerRegistrationRequest) ProtoMessage()

func (*TriggerRegistrationRequest) ProtoReflect added in v0.2.2 

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

func (*TriggerRegistrationRequest) Reset added in v0.2.2 

func (x *TriggerRegistrationRequest) Reset()

func (*TriggerRegistrationRequest) String added in v0.2.2 

func (x *TriggerRegistrationRequest) String() string

type TriggerResponse added in v0.2.2 

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
}

func TriggerResponseToProto added in v0.2.2 

func TriggerResponseToProto(resp capabilities.TriggerResponse) *TriggerResponse

func (*TriggerResponse) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) GetError added in v0.2.2 

func (x *TriggerResponse) GetError() string

func (*TriggerResponse) GetEvent added in v0.2.2 

func (x *TriggerResponse) GetEvent() *TriggerEvent

func (*TriggerResponse) ProtoMessage added in v0.2.2 

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect added in v0.2.2 

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

func (*TriggerResponse) Reset added in v0.2.2 

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String added in v0.2.2 

func (x *TriggerResponse) String() string

type TriggerResponseMessage added in v0.2.2 

type TriggerResponseMessage struct {

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

func (*TriggerResponseMessage) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use TriggerResponseMessage.ProtoReflect.Descriptor instead.

func (*TriggerResponseMessage) GetAck added in v0.2.2 

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

func (*TriggerResponseMessage) GetMessage added in v0.2.2 

func (m *TriggerResponseMessage) GetMessage() isTriggerResponseMessage_Message

func (*TriggerResponseMessage) GetResponse added in v0.2.2 

func (x *TriggerResponseMessage) GetResponse() *TriggerResponse

func (*TriggerResponseMessage) ProtoMessage added in v0.2.2 

func (*TriggerResponseMessage) ProtoMessage()

func (*TriggerResponseMessage) ProtoReflect added in v0.2.2 

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

func (*TriggerResponseMessage) Reset added in v0.2.2 

func (x *TriggerResponseMessage) Reset()

func (*TriggerResponseMessage) String added in v0.2.2 

func (x *TriggerResponseMessage) String() string

type TriggerResponseMessage_Ack added in v0.2.2 

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

type TriggerResponseMessage_Response added in v0.2.2 

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

type UnimplementedBaseCapabilityServer 

type UnimplementedBaseCapabilityServer struct {
}

UnimplementedBaseCapabilityServer must be embedded to have forward compatible implementations.

func (UnimplementedBaseCapabilityServer) Info 

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

type UnimplementedExecutableServer added in v0.2.2 

type UnimplementedExecutableServer struct {
}

UnimplementedExecutableServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutableServer) Execute added in v0.2.2 

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

func (UnimplementedExecutableServer) RegisterToWorkflow added in v0.2.2 

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

func (UnimplementedExecutableServer) UnregisterFromWorkflow added in v0.2.2 

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

type UnimplementedStandardCapabilitiesServer 

type UnimplementedStandardCapabilitiesServer struct {
}

UnimplementedStandardCapabilitiesServer must be embedded to have forward compatible implementations.

func (UnimplementedStandardCapabilitiesServer) Infos 

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

func (UnimplementedStandardCapabilitiesServer) Initialise 

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

type UnimplementedTriggerExecutableServer 

type UnimplementedTriggerExecutableServer struct {
}

UnimplementedTriggerExecutableServer must be embedded to have forward compatible implementations.

func (UnimplementedTriggerExecutableServer) RegisterTrigger 

func (UnimplementedTriggerExecutableServer) RegisterTrigger(*TriggerRegistrationRequest, TriggerExecutable_RegisterTriggerServer) error

func (UnimplementedTriggerExecutableServer) UnregisterTrigger 

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

type UnregisterFromWorkflowRequest 

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
}

func (*UnregisterFromWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterFromWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UnregisterFromWorkflowRequest) GetConfig 

func (x *UnregisterFromWorkflowRequest) GetConfig() *pb.Map

func (*UnregisterFromWorkflowRequest) GetMetadata 

func (x *UnregisterFromWorkflowRequest) GetMetadata() *RegistrationMetadata

func (*UnregisterFromWorkflowRequest) ProtoMessage 

func (*UnregisterFromWorkflowRequest) ProtoMessage()

func (*UnregisterFromWorkflowRequest) ProtoReflect 

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

func (*UnregisterFromWorkflowRequest) Reset 

func (x *UnregisterFromWorkflowRequest) Reset()

func (*UnregisterFromWorkflowRequest) String 

func (x *UnregisterFromWorkflowRequest) String() string

type UnsafeBaseCapabilityServer 

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

UnsafeBaseCapabilityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BaseCapabilityServer will result in compilation errors.

type UnsafeExecutableServer added in v0.2.2 

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

UnsafeExecutableServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutableServer will result in compilation errors.

type UnsafeStandardCapabilitiesServer 

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

UnsafeStandardCapabilitiesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StandardCapabilitiesServer will result in compilation errors.

type UnsafeTriggerExecutableServer 

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

UnsafeTriggerExecutableServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TriggerExecutableServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.