pb

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 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 

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

func MarshalTriggerResponse 

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

func RegisterBaseCapabilityServer 

func RegisterBaseCapabilityServer(s grpc.ServiceRegistrar, srv BaseCapabilityServer)

func RegisterExecutableServer 

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 

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

func TriggerResponseFromProto 

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 

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

func UnmarshalTriggerResponse 

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 

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 

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

Deprecated: Use CapabilityConfig.ProtoReflect.Descriptor instead.

func (*CapabilityConfig) GetDefaultConfig 

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

func (*CapabilityConfig) GetRemoteConfig 

func (m *CapabilityConfig) GetRemoteConfig() isCapabilityConfig_RemoteConfig

func (*CapabilityConfig) GetRemoteTargetConfig 

func (x *CapabilityConfig) GetRemoteTargetConfig() *RemoteTargetConfig

func (*CapabilityConfig) GetRemoteTriggerConfig 

func (x *CapabilityConfig) GetRemoteTriggerConfig() *RemoteTriggerConfig

func (*CapabilityConfig) ProtoMessage 

func (*CapabilityConfig) ProtoMessage()

func (*CapabilityConfig) ProtoReflect 

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

func (*CapabilityConfig) Reset 

func (x *CapabilityConfig) Reset()

func (*CapabilityConfig) String 

func (x *CapabilityConfig) String() string

type CapabilityConfig_RemoteTargetConfig 

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

type CapabilityConfig_RemoteTriggerConfig 

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 

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 

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 

func NewExecutableClient(cc grpc.ClientConnInterface) ExecutableClient

type ExecutableServer 

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 

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

type Executable_ExecuteServer 

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 

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 

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 

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

Deprecated: Use RemoteTargetConfig.ProtoReflect.Descriptor instead.

func (*RemoteTargetConfig) GetRequestHashExcludedAttributes 

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

func (*RemoteTargetConfig) ProtoMessage 

func (*RemoteTargetConfig) ProtoMessage()

func (*RemoteTargetConfig) ProtoReflect 

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

func (*RemoteTargetConfig) Reset 

func (x *RemoteTargetConfig) Reset()

func (*RemoteTargetConfig) String 

func (x *RemoteTargetConfig) String() string

type RemoteTriggerConfig 

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 

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

Deprecated: Use RemoteTriggerConfig.ProtoReflect.Descriptor instead.

func (*RemoteTriggerConfig) GetBatchCollectionPeriod 

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

func (*RemoteTriggerConfig) GetMaxBatchSize 

func (x *RemoteTriggerConfig) GetMaxBatchSize() uint32

func (*RemoteTriggerConfig) GetMessageExpiry 

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

func (*RemoteTriggerConfig) GetMinResponsesToAggregate 

func (x *RemoteTriggerConfig) GetMinResponsesToAggregate() uint32

func (*RemoteTriggerConfig) GetRegistrationExpiry 

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

func (*RemoteTriggerConfig) GetRegistrationRefresh 

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

func (*RemoteTriggerConfig) ProtoMessage 

func (*RemoteTriggerConfig) ProtoMessage()

func (*RemoteTriggerConfig) ProtoReflect 

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

func (*RemoteTriggerConfig) Reset 

func (x *RemoteTriggerConfig) Reset()

func (*RemoteTriggerConfig) String 

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 

func (x *RequestMetadata) GetReferenceId() string

func (*RequestMetadata) GetWorkflowDonConfigVersion 

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 

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 

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

Deprecated: Use TriggerEvent.ProtoReflect.Descriptor instead.

func (*TriggerEvent) GetId 

func (x *TriggerEvent) GetId() string

func (*TriggerEvent) GetOutputs 

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

func (*TriggerEvent) GetTriggerType 

func (x *TriggerEvent) GetTriggerType() string

func (*TriggerEvent) ProtoMessage 

func (*TriggerEvent) ProtoMessage()

func (*TriggerEvent) ProtoReflect 

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

func (*TriggerEvent) Reset 

func (x *TriggerEvent) Reset()

func (*TriggerEvent) String 

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 

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 

func TriggerRegistrationRequestToProto(req capabilities.TriggerRegistrationRequest) *TriggerRegistrationRequest

func (*TriggerRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use TriggerRegistrationRequest.ProtoReflect.Descriptor instead.

func (*TriggerRegistrationRequest) GetConfig 

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

func (*TriggerRegistrationRequest) GetMetadata 

func (x *TriggerRegistrationRequest) GetMetadata() *RequestMetadata

func (*TriggerRegistrationRequest) GetTriggerId 

func (x *TriggerRegistrationRequest) GetTriggerId() string

func (*TriggerRegistrationRequest) ProtoMessage 

func (*TriggerRegistrationRequest) ProtoMessage()

func (*TriggerRegistrationRequest) ProtoReflect 

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

func (*TriggerRegistrationRequest) Reset 

func (x *TriggerRegistrationRequest) Reset()

func (*TriggerRegistrationRequest) String 

func (x *TriggerRegistrationRequest) String() string

type TriggerResponse 

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 

func TriggerResponseToProto(resp capabilities.TriggerResponse) *TriggerResponse

func (*TriggerResponse) Descriptor deprecated 

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

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) GetError 

func (x *TriggerResponse) GetError() string

func (*TriggerResponse) GetEvent 

func (x *TriggerResponse) GetEvent() *TriggerEvent

func (*TriggerResponse) ProtoMessage 

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect 

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

func (*TriggerResponse) Reset 

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String 

func (x *TriggerResponse) String() string

type TriggerResponseMessage 

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 

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

Deprecated: Use TriggerResponseMessage.ProtoReflect.Descriptor instead.

func (*TriggerResponseMessage) GetAck 

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

func (*TriggerResponseMessage) GetMessage 

func (m *TriggerResponseMessage) GetMessage() isTriggerResponseMessage_Message

func (*TriggerResponseMessage) GetResponse 

func (x *TriggerResponseMessage) GetResponse() *TriggerResponse

func (*TriggerResponseMessage) ProtoMessage 

func (*TriggerResponseMessage) ProtoMessage()

func (*TriggerResponseMessage) ProtoReflect 

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

func (*TriggerResponseMessage) Reset 

func (x *TriggerResponseMessage) Reset()

func (*TriggerResponseMessage) String 

func (x *TriggerResponseMessage) String() string

type TriggerResponseMessage_Ack 

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

type TriggerResponseMessage_Response 

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 

type UnimplementedExecutableServer struct {
}

UnimplementedExecutableServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutableServer) Execute 

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

func (UnimplementedExecutableServer) RegisterToWorkflow 

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

func (UnimplementedExecutableServer) UnregisterFromWorkflow 

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 

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.