pb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2024 License: MIT Imports: 15 Imported by: 8

Documentation

Index

Constants

View Source 
const (
	TriggerExecutable_RegisterTrigger_FullMethodName   = "/loop.TriggerExecutable/RegisterTrigger"
	TriggerExecutable_UnregisterTrigger_FullMethodName = "/loop.TriggerExecutable/UnregisterTrigger"
)
View Source 
const (
	CallbackExecutable_RegisterToWorkflow_FullMethodName     = "/loop.CallbackExecutable/RegisterToWorkflow"
	CallbackExecutable_UnregisterFromWorkflow_FullMethodName = "/loop.CallbackExecutable/UnregisterFromWorkflow"
	CallbackExecutable_Execute_FullMethodName                = "/loop.CallbackExecutable/Execute"
)
View Source 
const (
	StandardCapabilities_Initialise_FullMethodName = "/loop.StandardCapabilities/Initialise"
	StandardCapabilities_Infos_FullMethodName      = "/loop.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 = "/loop.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: "loop.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 CallbackExecutable_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.CallbackExecutable",
	HandlerType: (*CallbackExecutableServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterToWorkflow",
			Handler:    _CallbackExecutable_RegisterToWorkflow_Handler,
		},
		{
			MethodName: "UnregisterFromWorkflow",
			Handler:    _CallbackExecutable_UnregisterFromWorkflow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _CallbackExecutable_Execute_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "capabilities/pb/capabilities.proto",
}

CallbackExecutable_ServiceDesc is the grpc.ServiceDesc for CallbackExecutable 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: "loop.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: "loop.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 RegisterBaseCapabilityServer 

func RegisterBaseCapabilityServer(s grpc.ServiceRegistrar, srv BaseCapabilityServer)

func RegisterCallbackExecutableServer added in v0.2.0 

func RegisterCallbackExecutableServer(s grpc.ServiceRegistrar, srv CallbackExecutableServer)

func RegisterStandardCapabilitiesServer 

func RegisterStandardCapabilitiesServer(s grpc.ServiceRegistrar, srv StandardCapabilitiesServer)

func RegisterTriggerExecutableServer 

func RegisterTriggerExecutableServer(s grpc.ServiceRegistrar, srv TriggerExecutableServer)

func UnmarshalCapabilityRequest 

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

func UnmarshalCapabilityResponse 

func UnmarshalCapabilityResponse(raw []byte) (capabilities.CapabilityResponse, 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 CallbackExecutableClient added in v0.2.0 

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

CallbackExecutableClient is the client API for CallbackExecutable 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 NewCallbackExecutableClient added in v0.2.0 

func NewCallbackExecutableClient(cc grpc.ClientConnInterface) CallbackExecutableClient

type CallbackExecutableServer added in v0.2.0 

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
}

CallbackExecutableServer is the server API for CallbackExecutable service. All implementations must embed UnimplementedCallbackExecutableServer for forward compatibility

type CallbackExecutable_ExecuteClient added in v0.2.0 

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

type CallbackExecutable_ExecuteServer added in v0.2.0 

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

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

func (*RemoteTriggerConfig) Descriptor deprecated 

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

Deprecated: Use RemoteTriggerConfig.ProtoReflect.Descriptor instead.

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 ResponseMessage added in v0.2.0 

type ResponseMessage struct {

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

func (*ResponseMessage) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ResponseMessage.ProtoReflect.Descriptor instead.

func (*ResponseMessage) GetAck added in v0.2.0 

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

func (*ResponseMessage) GetMessage added in v0.2.0 

func (m *ResponseMessage) GetMessage() isResponseMessage_Message

func (*ResponseMessage) GetResponse added in v0.2.0 

func (x *ResponseMessage) GetResponse() *CapabilityResponse

func (*ResponseMessage) ProtoMessage added in v0.2.0 

func (*ResponseMessage) ProtoMessage()

func (*ResponseMessage) ProtoReflect added in v0.2.0 

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

func (*ResponseMessage) Reset added in v0.2.0 

func (x *ResponseMessage) Reset()

func (*ResponseMessage) String added in v0.2.0 

func (x *ResponseMessage) String() string

type ResponseMessage_Ack added in v0.2.0 

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

type ResponseMessage_Response added in v0.2.0 

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

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 TriggerExecutableClient 

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

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(*CapabilityRequest, TriggerExecutable_RegisterTriggerServer) error
	UnregisterTrigger(context.Context, *CapabilityRequest) (*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() (*ResponseMessage, error)
	grpc.ClientStream
}

type TriggerExecutable_RegisterTriggerServer 

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

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 UnimplementedCallbackExecutableServer added in v0.2.0 

type UnimplementedCallbackExecutableServer struct {
}

UnimplementedCallbackExecutableServer must be embedded to have forward compatible implementations.

func (UnimplementedCallbackExecutableServer) Execute added in v0.2.0 

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

func (UnimplementedCallbackExecutableServer) RegisterToWorkflow added in v0.2.0 

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

func (UnimplementedCallbackExecutableServer) UnregisterFromWorkflow added in v0.2.0 

func (UnimplementedCallbackExecutableServer) 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(*CapabilityRequest, TriggerExecutable_RegisterTriggerServer) error

func (UnimplementedTriggerExecutableServer) UnregisterTrigger 

func (UnimplementedTriggerExecutableServer) UnregisterTrigger(context.Context, *CapabilityRequest) (*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 UnsafeCallbackExecutableServer added in v0.2.0 

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

UnsafeCallbackExecutableServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CallbackExecutableServer 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.