proto

package
v0.23.1 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProcessingGuarantees_name = map[int32]string{
		0: "ATLEAST_ONCE",
		1: "ATMOST_ONCE",
		2: "EFFECTIVELY_ONCE",
		3: "MANUAL",
	}
	ProcessingGuarantees_value = map[string]int32{
		"ATLEAST_ONCE":     0,
		"ATMOST_ONCE":      1,
		"EFFECTIVELY_ONCE": 2,
		"MANUAL":           3,
	}
)

Enum value maps for ProcessingGuarantees.

View Source 
var (
	SubscriptionType_name = map[int32]string{
		0: "SHARED",
		1: "FAILOVER",
		2: "KEY_SHARED",
	}
	SubscriptionType_value = map[string]int32{
		"SHARED":     0,
		"FAILOVER":   1,
		"KEY_SHARED": 2,
	}
)

Enum value maps for SubscriptionType.

View Source 
var (
	SubscriptionPosition_name = map[int32]string{
		0: "LATEST",
		1: "EARLIEST",
	}
	SubscriptionPosition_value = map[string]int32{
		"LATEST":   0,
		"EARLIEST": 1,
	}
)

Enum value maps for SubscriptionPosition.

View Source 
var (
	CompressionType_name = map[int32]string{
		0: "LZ4",
		1: "NONE",
		2: "ZLIB",
		3: "ZSTD",
		4: "SNAPPY",
	}
	CompressionType_value = map[string]int32{
		"LZ4":    0,
		"NONE":   1,
		"ZLIB":   2,
		"ZSTD":   3,
		"SNAPPY": 4,
	}
)

Enum value maps for CompressionType.

View Source 
var (
	FunctionState_name = map[int32]string{
		0: "RUNNING",
		1: "STOPPED",
	}
	FunctionState_value = map[string]int32{
		"RUNNING": 0,
		"STOPPED": 1,
	}
)

Enum value maps for FunctionState.

View Source 
var (
	FunctionDetails_Runtime_name = map[int32]string{
		0: "JAVA",
		1: "PYTHON",
		3: "GO",
	}
	FunctionDetails_Runtime_value = map[string]int32{
		"JAVA":   0,
		"PYTHON": 1,
		"GO":     3,
	}
)

Enum value maps for FunctionDetails_Runtime.

View Source 
var (
	FunctionDetails_ComponentType_name = map[int32]string{
		0: "UNKNOWN",
		1: "FUNCTION",
		2: "SOURCE",
		3: "SINK",
	}
	FunctionDetails_ComponentType_value = map[string]int32{
		"UNKNOWN":  0,
		"FUNCTION": 1,
		"SOURCE":   2,
		"SINK":     3,
	}
)

Enum value maps for FunctionDetails_ComponentType.

View Source 
var (
	CryptoSpec_FailureAction_name = map[int32]string{
		0:  "FAIL",
		1:  "DISCARD",
		2:  "CONSUME",
		10: "SEND",
	}
	CryptoSpec_FailureAction_value = map[string]int32{
		"FAIL":    0,
		"DISCARD": 1,
		"CONSUME": 2,
		"SEND":    10,
	}
)

Enum value maps for CryptoSpec_FailureAction.

View Source 
var File_Function_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Assignment 

type Assignment struct {
	Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	WorkerId string    `protobuf:"bytes,2,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*Assignment) Descriptor deprecated 

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

Deprecated: Use Assignment.ProtoReflect.Descriptor instead.

func (*Assignment) GetInstance 

func (x *Assignment) GetInstance() *Instance

func (*Assignment) GetWorkerId 

func (x *Assignment) GetWorkerId() string

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) ProtoReflect 

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

func (*Assignment) Reset 

func (x *Assignment) Reset()

func (*Assignment) String 

func (x *Assignment) String() string

type CompressionType added in v0.14.0 

type CompressionType int32
const (
	CompressionType_LZ4    CompressionType = 0
	CompressionType_NONE   CompressionType = 1
	CompressionType_ZLIB   CompressionType = 2
	CompressionType_ZSTD   CompressionType = 3
	CompressionType_SNAPPY CompressionType = 4
)

func (CompressionType) Descriptor added in v0.14.0 

func (CompressionType) Descriptor() protoreflect.EnumDescriptor

func (CompressionType) Enum added in v0.14.0 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated added in v0.14.0 

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

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Number added in v0.14.0 

func (x CompressionType) Number() protoreflect.EnumNumber

func (CompressionType) String added in v0.14.0 

func (x CompressionType) String() string

func (CompressionType) Type added in v0.14.0 

func (CompressionType) Type() protoreflect.EnumType

type ConsumerSpec 

type ConsumerSpec struct {
	SchemaType         string                          `protobuf:"bytes,1,opt,name=schemaType,proto3" json:"schemaType,omitempty"`
	SerdeClassName     string                          `protobuf:"bytes,2,opt,name=serdeClassName,proto3" json:"serdeClassName,omitempty"`
	IsRegexPattern     bool                            `protobuf:"varint,3,opt,name=isRegexPattern,proto3" json:"isRegexPattern,omitempty"`
	ReceiverQueueSize  *ConsumerSpec_ReceiverQueueSize `protobuf:"bytes,4,opt,name=receiverQueueSize,proto3" json:"receiverQueueSize,omitempty"`
	SchemaProperties   map[string]string               `` /* 173-byte string literal not displayed */
	ConsumerProperties map[string]string               `` /* 177-byte string literal not displayed */
	CryptoSpec         *CryptoSpec                     `protobuf:"bytes,7,opt,name=cryptoSpec,proto3" json:"cryptoSpec,omitempty"`
	PoolMessages       bool                            `protobuf:"varint,8,opt,name=poolMessages,proto3" json:"poolMessages,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerSpec) Descriptor deprecated 

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

Deprecated: Use ConsumerSpec.ProtoReflect.Descriptor instead.

func (*ConsumerSpec) GetConsumerProperties 

func (x *ConsumerSpec) GetConsumerProperties() map[string]string

func (*ConsumerSpec) GetCryptoSpec 

func (x *ConsumerSpec) GetCryptoSpec() *CryptoSpec

func (*ConsumerSpec) GetIsRegexPattern 

func (x *ConsumerSpec) GetIsRegexPattern() bool

func (*ConsumerSpec) GetPoolMessages 

func (x *ConsumerSpec) GetPoolMessages() bool

func (*ConsumerSpec) GetReceiverQueueSize 

func (x *ConsumerSpec) GetReceiverQueueSize() *ConsumerSpec_ReceiverQueueSize

func (*ConsumerSpec) GetSchemaProperties 

func (x *ConsumerSpec) GetSchemaProperties() map[string]string

func (*ConsumerSpec) GetSchemaType 

func (x *ConsumerSpec) GetSchemaType() string

func (*ConsumerSpec) GetSerdeClassName 

func (x *ConsumerSpec) GetSerdeClassName() string

func (*ConsumerSpec) ProtoMessage 

func (*ConsumerSpec) ProtoMessage()

func (*ConsumerSpec) ProtoReflect 

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

func (*ConsumerSpec) Reset 

func (x *ConsumerSpec) Reset()

func (*ConsumerSpec) String 

func (x *ConsumerSpec) String() string

type ConsumerSpec_ReceiverQueueSize 

type ConsumerSpec_ReceiverQueueSize struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerSpec_ReceiverQueueSize) Descriptor deprecated 

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

Deprecated: Use ConsumerSpec_ReceiverQueueSize.ProtoReflect.Descriptor instead.

func (*ConsumerSpec_ReceiverQueueSize) GetValue 

func (x *ConsumerSpec_ReceiverQueueSize) GetValue() int32

func (*ConsumerSpec_ReceiverQueueSize) ProtoMessage 

func (*ConsumerSpec_ReceiverQueueSize) ProtoMessage()

func (*ConsumerSpec_ReceiverQueueSize) ProtoReflect 

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

func (*ConsumerSpec_ReceiverQueueSize) Reset 

func (x *ConsumerSpec_ReceiverQueueSize) Reset()

func (*ConsumerSpec_ReceiverQueueSize) String 

func (x *ConsumerSpec_ReceiverQueueSize) String() string

type CryptoSpec 

type CryptoSpec struct {
	CryptoKeyReaderClassName string `protobuf:"bytes,1,opt,name=cryptoKeyReaderClassName,proto3" json:"cryptoKeyReaderClassName,omitempty"`
	CryptoKeyReaderConfig    string `protobuf:"bytes,2,opt,name=cryptoKeyReaderConfig,proto3" json:"cryptoKeyReaderConfig,omitempty"`
	// key names used by producer to encrypt data
	ProducerEncryptionKeyName []string `protobuf:"bytes,3,rep,name=producerEncryptionKeyName,proto3" json:"producerEncryptionKeyName,omitempty"`
	// define the action if producer fail to encrypt data
	// one of FAIL, SEND
	ProducerCryptoFailureAction CryptoSpec_FailureAction `` /* 144-byte string literal not displayed */
	// define the action if consumer fail to decrypt data
	// one of FAIL, DISCARD, CONSUME
	ConsumerCryptoFailureAction CryptoSpec_FailureAction `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CryptoSpec) Descriptor deprecated 

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

Deprecated: Use CryptoSpec.ProtoReflect.Descriptor instead.

func (*CryptoSpec) GetConsumerCryptoFailureAction 

func (x *CryptoSpec) GetConsumerCryptoFailureAction() CryptoSpec_FailureAction

func (*CryptoSpec) GetCryptoKeyReaderClassName 

func (x *CryptoSpec) GetCryptoKeyReaderClassName() string

func (*CryptoSpec) GetCryptoKeyReaderConfig 

func (x *CryptoSpec) GetCryptoKeyReaderConfig() string

func (*CryptoSpec) GetProducerCryptoFailureAction 

func (x *CryptoSpec) GetProducerCryptoFailureAction() CryptoSpec_FailureAction

func (*CryptoSpec) GetProducerEncryptionKeyName 

func (x *CryptoSpec) GetProducerEncryptionKeyName() []string

func (*CryptoSpec) ProtoMessage 

func (*CryptoSpec) ProtoMessage()

func (*CryptoSpec) ProtoReflect 

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

func (*CryptoSpec) Reset 

func (x *CryptoSpec) Reset()

func (*CryptoSpec) String 

func (x *CryptoSpec) String() string

type CryptoSpec_FailureAction 

type CryptoSpec_FailureAction int32
const (
	CryptoSpec_FAIL    CryptoSpec_FailureAction = 0
	CryptoSpec_DISCARD CryptoSpec_FailureAction = 1
	CryptoSpec_CONSUME CryptoSpec_FailureAction = 2
	CryptoSpec_SEND    CryptoSpec_FailureAction = 10
)

func (CryptoSpec_FailureAction) Descriptor 

func (CryptoSpec_FailureAction) Descriptor() protoreflect.EnumDescriptor

func (CryptoSpec_FailureAction) Enum 

func (x CryptoSpec_FailureAction) Enum() *CryptoSpec_FailureAction

func (CryptoSpec_FailureAction) EnumDescriptor deprecated 

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

Deprecated: Use CryptoSpec_FailureAction.Descriptor instead.

func (CryptoSpec_FailureAction) Number 

func (x CryptoSpec_FailureAction) Number() protoreflect.EnumNumber

func (CryptoSpec_FailureAction) String 

func (x CryptoSpec_FailureAction) String() string

func (CryptoSpec_FailureAction) Type 

func (CryptoSpec_FailureAction) Type() protoreflect.EnumType

type FunctionAuthenticationSpec 

type FunctionAuthenticationSpec struct {

	// *
	// function authentication related data that the function authentication provider
	// needs to cache/distribute to all workers support function authentication.
	// Depending on the function authentication provider implementation, this can be the actual auth credentials
	// or a pointer to the auth credentials that this function should use
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// *
	// classname of the function auth provicer this data is relevant to
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionAuthenticationSpec) Descriptor deprecated 

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

Deprecated: Use FunctionAuthenticationSpec.ProtoReflect.Descriptor instead.

func (*FunctionAuthenticationSpec) GetData 

func (x *FunctionAuthenticationSpec) GetData() []byte

func (*FunctionAuthenticationSpec) GetProvider 

func (x *FunctionAuthenticationSpec) GetProvider() string

func (*FunctionAuthenticationSpec) ProtoMessage 

func (*FunctionAuthenticationSpec) ProtoMessage()

func (*FunctionAuthenticationSpec) ProtoReflect 

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

func (*FunctionAuthenticationSpec) Reset 

func (x *FunctionAuthenticationSpec) Reset()

func (*FunctionAuthenticationSpec) String 

func (x *FunctionAuthenticationSpec) String() string

type FunctionDetails 

type FunctionDetails struct {
	Tenant               string                  `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Namespace            string                  `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string                  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ClassName            string                  `protobuf:"bytes,4,opt,name=className,proto3" json:"className,omitempty"`
	LogTopic             string                  `protobuf:"bytes,5,opt,name=logTopic,proto3" json:"logTopic,omitempty"`
	ProcessingGuarantees ProcessingGuarantees    `` /* 126-byte string literal not displayed */
	UserConfig           string                  `protobuf:"bytes,7,opt,name=userConfig,proto3" json:"userConfig,omitempty"`
	SecretsMap           string                  `protobuf:"bytes,16,opt,name=secretsMap,proto3" json:"secretsMap,omitempty"`
	Runtime              FunctionDetails_Runtime `protobuf:"varint,8,opt,name=runtime,proto3,enum=proto.FunctionDetails_Runtime" json:"runtime,omitempty"`
	// Deprecated since, see https://github.com/apache/pulsar/issues/15560
	//
	AutoAck              bool                          `protobuf:"varint,9,opt,name=autoAck,proto3" json:"autoAck,omitempty"`
	Parallelism          int32                         `protobuf:"varint,10,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	Source               *SourceSpec                   `protobuf:"bytes,11,opt,name=source,proto3" json:"source,omitempty"`
	Sink                 *SinkSpec                     `protobuf:"bytes,12,opt,name=sink,proto3" json:"sink,omitempty"`
	Resources            *Resources                    `protobuf:"bytes,13,opt,name=resources,proto3" json:"resources,omitempty"`
	PackageUrl           string                        `protobuf:"bytes,14,opt,name=packageUrl,proto3" json:"packageUrl,omitempty"` //present only if function submitted with package-url
	RetryDetails         *RetryDetails                 `protobuf:"bytes,15,opt,name=retryDetails,proto3" json:"retryDetails,omitempty"`
	RuntimeFlags         string                        `protobuf:"bytes,17,opt,name=runtimeFlags,proto3" json:"runtimeFlags,omitempty"`
	ComponentType        FunctionDetails_ComponentType `protobuf:"varint,18,opt,name=componentType,proto3,enum=proto.FunctionDetails_ComponentType" json:"componentType,omitempty"`
	CustomRuntimeOptions string                        `protobuf:"bytes,19,opt,name=customRuntimeOptions,proto3" json:"customRuntimeOptions,omitempty"`
	// If specified, this will refer to an archive that is
	// already present in the server
	Builtin              string               `protobuf:"bytes,20,opt,name=builtin,proto3" json:"builtin,omitempty"`
	RetainOrdering       bool                 `protobuf:"varint,21,opt,name=retainOrdering,proto3" json:"retainOrdering,omitempty"`
	RetainKeyOrdering    bool                 `protobuf:"varint,22,opt,name=retainKeyOrdering,proto3" json:"retainKeyOrdering,omitempty"`
	SubscriptionPosition SubscriptionPosition `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FunctionDetails) Descriptor deprecated 

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

Deprecated: Use FunctionDetails.ProtoReflect.Descriptor instead.

func (*FunctionDetails) GetAutoAck deprecated 

func (x *FunctionDetails) GetAutoAck() bool

Deprecated: Do not use.

func (*FunctionDetails) GetBuiltin 

func (x *FunctionDetails) GetBuiltin() string

func (*FunctionDetails) GetClassName 

func (x *FunctionDetails) GetClassName() string

func (*FunctionDetails) GetComponentType 

func (x *FunctionDetails) GetComponentType() FunctionDetails_ComponentType

func (*FunctionDetails) GetCustomRuntimeOptions 

func (x *FunctionDetails) GetCustomRuntimeOptions() string

func (*FunctionDetails) GetLogTopic 

func (x *FunctionDetails) GetLogTopic() string

func (*FunctionDetails) GetName 

func (x *FunctionDetails) GetName() string

func (*FunctionDetails) GetNamespace 

func (x *FunctionDetails) GetNamespace() string

func (*FunctionDetails) GetPackageUrl 

func (x *FunctionDetails) GetPackageUrl() string

func (*FunctionDetails) GetParallelism 

func (x *FunctionDetails) GetParallelism() int32

func (*FunctionDetails) GetProcessingGuarantees 

func (x *FunctionDetails) GetProcessingGuarantees() ProcessingGuarantees

func (*FunctionDetails) GetResources 

func (x *FunctionDetails) GetResources() *Resources

func (*FunctionDetails) GetRetainKeyOrdering 

func (x *FunctionDetails) GetRetainKeyOrdering() bool

func (*FunctionDetails) GetRetainOrdering 

func (x *FunctionDetails) GetRetainOrdering() bool

func (*FunctionDetails) GetRetryDetails 

func (x *FunctionDetails) GetRetryDetails() *RetryDetails

func (*FunctionDetails) GetRuntime 

func (x *FunctionDetails) GetRuntime() FunctionDetails_Runtime

func (*FunctionDetails) GetRuntimeFlags 

func (x *FunctionDetails) GetRuntimeFlags() string

func (*FunctionDetails) GetSecretsMap 

func (x *FunctionDetails) GetSecretsMap() string

func (*FunctionDetails) GetSink 

func (x *FunctionDetails) GetSink() *SinkSpec

func (*FunctionDetails) GetSource 

func (x *FunctionDetails) GetSource() *SourceSpec

func (*FunctionDetails) GetSubscriptionPosition 

func (x *FunctionDetails) GetSubscriptionPosition() SubscriptionPosition

func (*FunctionDetails) GetTenant 

func (x *FunctionDetails) GetTenant() string

func (*FunctionDetails) GetUserConfig 

func (x *FunctionDetails) GetUserConfig() string

func (*FunctionDetails) ProtoMessage 

func (*FunctionDetails) ProtoMessage()

func (*FunctionDetails) ProtoReflect 

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

func (*FunctionDetails) Reset 

func (x *FunctionDetails) Reset()

func (*FunctionDetails) String 

func (x *FunctionDetails) String() string

type FunctionDetails_ComponentType 

type FunctionDetails_ComponentType int32
const (
	FunctionDetails_UNKNOWN  FunctionDetails_ComponentType = 0
	FunctionDetails_FUNCTION FunctionDetails_ComponentType = 1
	FunctionDetails_SOURCE   FunctionDetails_ComponentType = 2
	FunctionDetails_SINK     FunctionDetails_ComponentType = 3
)

func (FunctionDetails_ComponentType) Descriptor 

func (FunctionDetails_ComponentType) Descriptor() protoreflect.EnumDescriptor

func (FunctionDetails_ComponentType) Enum 

func (x FunctionDetails_ComponentType) Enum() *FunctionDetails_ComponentType

func (FunctionDetails_ComponentType) EnumDescriptor deprecated 

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

Deprecated: Use FunctionDetails_ComponentType.Descriptor instead.

func (FunctionDetails_ComponentType) Number 

func (x FunctionDetails_ComponentType) Number() protoreflect.EnumNumber

func (FunctionDetails_ComponentType) String 

func (x FunctionDetails_ComponentType) String() string

func (FunctionDetails_ComponentType) Type 

func (FunctionDetails_ComponentType) Type() protoreflect.EnumType

type FunctionDetails_Runtime 

type FunctionDetails_Runtime int32
const (
	FunctionDetails_JAVA   FunctionDetails_Runtime = 0
	FunctionDetails_PYTHON FunctionDetails_Runtime = 1
	FunctionDetails_GO     FunctionDetails_Runtime = 3
)

func (FunctionDetails_Runtime) Descriptor 

func (FunctionDetails_Runtime) Descriptor() protoreflect.EnumDescriptor

func (FunctionDetails_Runtime) Enum 

func (x FunctionDetails_Runtime) Enum() *FunctionDetails_Runtime

func (FunctionDetails_Runtime) EnumDescriptor deprecated 

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

Deprecated: Use FunctionDetails_Runtime.Descriptor instead.

func (FunctionDetails_Runtime) Number 

func (x FunctionDetails_Runtime) Number() protoreflect.EnumNumber

func (FunctionDetails_Runtime) String 

func (x FunctionDetails_Runtime) String() string

func (FunctionDetails_Runtime) Type 

func (FunctionDetails_Runtime) Type() protoreflect.EnumType

type FunctionMetaData 

type FunctionMetaData struct {
	FunctionDetails                  *FunctionDetails            `protobuf:"bytes,1,opt,name=functionDetails,proto3" json:"functionDetails,omitempty"`
	PackageLocation                  *PackageLocationMetaData    `protobuf:"bytes,2,opt,name=packageLocation,proto3" json:"packageLocation,omitempty"`
	Version                          uint64                      `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime                       uint64                      `protobuf:"varint,4,opt,name=createTime,proto3" json:"createTime,omitempty"`
	InstanceStates                   map[int32]FunctionState     `` /* 196-byte string literal not displayed */
	FunctionAuthSpec                 *FunctionAuthenticationSpec `protobuf:"bytes,6,opt,name=functionAuthSpec,proto3" json:"functionAuthSpec,omitempty"`
	TransformFunctionPackageLocation *PackageLocationMetaData    `protobuf:"bytes,7,opt,name=transformFunctionPackageLocation,proto3" json:"transformFunctionPackageLocation,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionMetaData) Descriptor deprecated 

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

Deprecated: Use FunctionMetaData.ProtoReflect.Descriptor instead.

func (*FunctionMetaData) GetCreateTime 

func (x *FunctionMetaData) GetCreateTime() uint64

func (*FunctionMetaData) GetFunctionAuthSpec 

func (x *FunctionMetaData) GetFunctionAuthSpec() *FunctionAuthenticationSpec

func (*FunctionMetaData) GetFunctionDetails 

func (x *FunctionMetaData) GetFunctionDetails() *FunctionDetails

func (*FunctionMetaData) GetInstanceStates 

func (x *FunctionMetaData) GetInstanceStates() map[int32]FunctionState

func (*FunctionMetaData) GetPackageLocation 

func (x *FunctionMetaData) GetPackageLocation() *PackageLocationMetaData

func (*FunctionMetaData) GetTransformFunctionPackageLocation added in v0.14.0 

func (x *FunctionMetaData) GetTransformFunctionPackageLocation() *PackageLocationMetaData

func (*FunctionMetaData) GetVersion 

func (x *FunctionMetaData) GetVersion() uint64

func (*FunctionMetaData) ProtoMessage 

func (*FunctionMetaData) ProtoMessage()

func (*FunctionMetaData) ProtoReflect 

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

func (*FunctionMetaData) Reset 

func (x *FunctionMetaData) Reset()

func (*FunctionMetaData) String 

func (x *FunctionMetaData) String() string

type FunctionState 

type FunctionState int32
const (
	FunctionState_RUNNING FunctionState = 0
	FunctionState_STOPPED FunctionState = 1
)

func (FunctionState) Descriptor 

func (FunctionState) Descriptor() protoreflect.EnumDescriptor

func (FunctionState) Enum 

func (x FunctionState) Enum() *FunctionState

func (FunctionState) EnumDescriptor deprecated 

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

Deprecated: Use FunctionState.Descriptor instead.

func (FunctionState) Number 

func (x FunctionState) Number() protoreflect.EnumNumber

func (FunctionState) String 

func (x FunctionState) String() string

func (FunctionState) Type 

func (FunctionState) Type() protoreflect.EnumType

type Instance 

type Instance struct {
	FunctionMetaData *FunctionMetaData `protobuf:"bytes,1,opt,name=functionMetaData,proto3" json:"functionMetaData,omitempty"`
	InstanceId       int32             `protobuf:"varint,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance) Descriptor deprecated 

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetFunctionMetaData 

func (x *Instance) GetFunctionMetaData() *FunctionMetaData

func (*Instance) GetInstanceId 

func (x *Instance) GetInstanceId() int32

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

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

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type PackageLocationMetaData 

type PackageLocationMetaData struct {
	PackagePath      string `protobuf:"bytes,1,opt,name=packagePath,proto3" json:"packagePath,omitempty"`
	OriginalFileName string `protobuf:"bytes,2,opt,name=originalFileName,proto3" json:"originalFileName,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageLocationMetaData) Descriptor deprecated 

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

Deprecated: Use PackageLocationMetaData.ProtoReflect.Descriptor instead.

func (*PackageLocationMetaData) GetOriginalFileName 

func (x *PackageLocationMetaData) GetOriginalFileName() string

func (*PackageLocationMetaData) GetPackagePath 

func (x *PackageLocationMetaData) GetPackagePath() string

func (*PackageLocationMetaData) ProtoMessage 

func (*PackageLocationMetaData) ProtoMessage()

func (*PackageLocationMetaData) ProtoReflect 

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

func (*PackageLocationMetaData) Reset 

func (x *PackageLocationMetaData) Reset()

func (*PackageLocationMetaData) String 

func (x *PackageLocationMetaData) String() string

type ProcessingGuarantees 

type ProcessingGuarantees int32
const (
	ProcessingGuarantees_ATLEAST_ONCE     ProcessingGuarantees = 0 // [default value]
	ProcessingGuarantees_ATMOST_ONCE      ProcessingGuarantees = 1
	ProcessingGuarantees_EFFECTIVELY_ONCE ProcessingGuarantees = 2
	ProcessingGuarantees_MANUAL           ProcessingGuarantees = 3
)

func (ProcessingGuarantees) Descriptor 

func (ProcessingGuarantees) Descriptor() protoreflect.EnumDescriptor

func (ProcessingGuarantees) Enum 

func (x ProcessingGuarantees) Enum() *ProcessingGuarantees

func (ProcessingGuarantees) EnumDescriptor deprecated 

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

Deprecated: Use ProcessingGuarantees.Descriptor instead.

func (ProcessingGuarantees) Number 

func (x ProcessingGuarantees) Number() protoreflect.EnumNumber

func (ProcessingGuarantees) String 

func (x ProcessingGuarantees) String() string

func (ProcessingGuarantees) Type 

func (ProcessingGuarantees) Type() protoreflect.EnumType

type ProducerSpec 

type ProducerSpec struct {
	MaxPendingMessages                 int32           `protobuf:"varint,1,opt,name=maxPendingMessages,proto3" json:"maxPendingMessages,omitempty"`
	MaxPendingMessagesAcrossPartitions int32           `protobuf:"varint,2,opt,name=maxPendingMessagesAcrossPartitions,proto3" json:"maxPendingMessagesAcrossPartitions,omitempty"`
	UseThreadLocalProducers            bool            `protobuf:"varint,3,opt,name=useThreadLocalProducers,proto3" json:"useThreadLocalProducers,omitempty"`
	CryptoSpec                         *CryptoSpec     `protobuf:"bytes,4,opt,name=cryptoSpec,proto3" json:"cryptoSpec,omitempty"`
	BatchBuilder                       string          `protobuf:"bytes,5,opt,name=batchBuilder,proto3" json:"batchBuilder,omitempty"`
	CompressionType                    CompressionType `protobuf:"varint,6,opt,name=compressionType,proto3,enum=proto.CompressionType" json:"compressionType,omitempty"`
	// contains filtered or unexported fields
}

func (*ProducerSpec) Descriptor deprecated 

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

Deprecated: Use ProducerSpec.ProtoReflect.Descriptor instead.

func (*ProducerSpec) GetBatchBuilder 

func (x *ProducerSpec) GetBatchBuilder() string

func (*ProducerSpec) GetCompressionType added in v0.14.0 

func (x *ProducerSpec) GetCompressionType() CompressionType

func (*ProducerSpec) GetCryptoSpec 

func (x *ProducerSpec) GetCryptoSpec() *CryptoSpec

func (*ProducerSpec) GetMaxPendingMessages 

func (x *ProducerSpec) GetMaxPendingMessages() int32

func (*ProducerSpec) GetMaxPendingMessagesAcrossPartitions 

func (x *ProducerSpec) GetMaxPendingMessagesAcrossPartitions() int32

func (*ProducerSpec) GetUseThreadLocalProducers 

func (x *ProducerSpec) GetUseThreadLocalProducers() bool

func (*ProducerSpec) ProtoMessage 

func (*ProducerSpec) ProtoMessage()

func (*ProducerSpec) ProtoReflect 

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

func (*ProducerSpec) Reset 

func (x *ProducerSpec) Reset()

func (*ProducerSpec) String 

func (x *ProducerSpec) String() string

type Resources 

type Resources struct {
	Cpu  float64 `protobuf:"fixed64,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Ram  int64   `protobuf:"varint,2,opt,name=ram,proto3" json:"ram,omitempty"`
	Disk int64   `protobuf:"varint,3,opt,name=disk,proto3" json:"disk,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpu 

func (x *Resources) GetCpu() float64

func (*Resources) GetDisk 

func (x *Resources) GetDisk() int64

func (*Resources) GetRam 

func (x *Resources) GetRam() int64

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) String 

func (x *Resources) String() string

type RetryDetails 

type RetryDetails struct {
	MaxMessageRetries int32  `protobuf:"varint,1,opt,name=maxMessageRetries,proto3" json:"maxMessageRetries,omitempty"`
	DeadLetterTopic   string `protobuf:"bytes,2,opt,name=deadLetterTopic,proto3" json:"deadLetterTopic,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryDetails) Descriptor deprecated 

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

Deprecated: Use RetryDetails.ProtoReflect.Descriptor instead.

func (*RetryDetails) GetDeadLetterTopic 

func (x *RetryDetails) GetDeadLetterTopic() string

func (*RetryDetails) GetMaxMessageRetries 

func (x *RetryDetails) GetMaxMessageRetries() int32

func (*RetryDetails) ProtoMessage 

func (*RetryDetails) ProtoMessage()

func (*RetryDetails) ProtoReflect 

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

func (*RetryDetails) Reset 

func (x *RetryDetails) Reset()

func (*RetryDetails) String 

func (x *RetryDetails) String() string

type SinkSpec 

type SinkSpec struct {
	ClassName string `protobuf:"bytes,1,opt,name=className,proto3" json:"className,omitempty"`
	// map in json format
	Configs       string `protobuf:"bytes,2,opt,name=configs,proto3" json:"configs,omitempty"`
	TypeClassName string `protobuf:"bytes,5,opt,name=typeClassName,proto3" json:"typeClassName,omitempty"`
	// configs used only when functions output to sink
	Topic          string        `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	ProducerSpec   *ProducerSpec `protobuf:"bytes,11,opt,name=producerSpec,proto3" json:"producerSpec,omitempty"`
	SerDeClassName string        `protobuf:"bytes,4,opt,name=serDeClassName,proto3" json:"serDeClassName,omitempty"`
	// If specified, this will refer to an archive that is
	// already present in the server
	Builtin string `protobuf:"bytes,6,opt,name=builtin,proto3" json:"builtin,omitempty"`
	// *
	// Builtin schema type or custom schema class name
	SchemaType                   string            `protobuf:"bytes,7,opt,name=schemaType,proto3" json:"schemaType,omitempty"`
	ForwardSourceMessageProperty bool              `protobuf:"varint,8,opt,name=forwardSourceMessageProperty,proto3" json:"forwardSourceMessageProperty,omitempty"`
	SchemaProperties             map[string]string `` /* 173-byte string literal not displayed */
	ConsumerProperties           map[string]string `` /* 178-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SinkSpec) Descriptor deprecated 

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

Deprecated: Use SinkSpec.ProtoReflect.Descriptor instead.

func (*SinkSpec) GetBuiltin 

func (x *SinkSpec) GetBuiltin() string

func (*SinkSpec) GetClassName 

func (x *SinkSpec) GetClassName() string

func (*SinkSpec) GetConfigs 

func (x *SinkSpec) GetConfigs() string

func (*SinkSpec) GetConsumerProperties 

func (x *SinkSpec) GetConsumerProperties() map[string]string

func (*SinkSpec) GetForwardSourceMessageProperty 

func (x *SinkSpec) GetForwardSourceMessageProperty() bool

func (*SinkSpec) GetProducerSpec 

func (x *SinkSpec) GetProducerSpec() *ProducerSpec

func (*SinkSpec) GetSchemaProperties 

func (x *SinkSpec) GetSchemaProperties() map[string]string

func (*SinkSpec) GetSchemaType 

func (x *SinkSpec) GetSchemaType() string

func (*SinkSpec) GetSerDeClassName 

func (x *SinkSpec) GetSerDeClassName() string

func (*SinkSpec) GetTopic 

func (x *SinkSpec) GetTopic() string

func (*SinkSpec) GetTypeClassName 

func (x *SinkSpec) GetTypeClassName() string

func (*SinkSpec) ProtoMessage 

func (*SinkSpec) ProtoMessage()

func (*SinkSpec) ProtoReflect 

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

func (*SinkSpec) Reset 

func (x *SinkSpec) Reset()

func (*SinkSpec) String 

func (x *SinkSpec) String() string

type SourceSpec 

type SourceSpec struct {
	ClassName string `protobuf:"bytes,1,opt,name=className,proto3" json:"className,omitempty"`
	// map in json format
	Configs       string `protobuf:"bytes,2,opt,name=configs,proto3" json:"configs,omitempty"`
	TypeClassName string `protobuf:"bytes,5,opt,name=typeClassName,proto3" json:"typeClassName,omitempty"`
	// configs used only when source feeds into functions
	SubscriptionType SubscriptionType `protobuf:"varint,3,opt,name=subscriptionType,proto3,enum=proto.SubscriptionType" json:"subscriptionType,omitempty"`
	// @deprecated -- use topicsToSchema
	//
	// Deprecated: Do not use.
	TopicsToSerDeClassName map[string]string `` /* 185-byte string literal not displayed */
	// *
	InputSpecs map[string]*ConsumerSpec `` /* 162-byte string literal not displayed */
	TimeoutMs  uint64                   `protobuf:"varint,6,opt,name=timeoutMs,proto3" json:"timeoutMs,omitempty"`
	// Deprecated: Do not use.
	TopicsPattern string `protobuf:"bytes,7,opt,name=topicsPattern,proto3" json:"topicsPattern,omitempty"`
	// If specified, this will refer to an archive that is
	// already present in the server
	Builtin                      string               `protobuf:"bytes,8,opt,name=builtin,proto3" json:"builtin,omitempty"`
	SubscriptionName             string               `protobuf:"bytes,9,opt,name=subscriptionName,proto3" json:"subscriptionName,omitempty"`
	CleanupSubscription          bool                 `protobuf:"varint,11,opt,name=cleanupSubscription,proto3" json:"cleanupSubscription,omitempty"`
	SubscriptionPosition         SubscriptionPosition `` /* 127-byte string literal not displayed */
	NegativeAckRedeliveryDelayMs uint64               `protobuf:"varint,13,opt,name=negativeAckRedeliveryDelayMs,proto3" json:"negativeAckRedeliveryDelayMs,omitempty"`
	SkipToLatest                 bool                 `protobuf:"varint,14,opt,name=skipToLatest,proto3" json:"skipToLatest,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceSpec) Descriptor deprecated 

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

Deprecated: Use SourceSpec.ProtoReflect.Descriptor instead.

func (*SourceSpec) GetBuiltin 

func (x *SourceSpec) GetBuiltin() string

func (*SourceSpec) GetClassName 

func (x *SourceSpec) GetClassName() string

func (*SourceSpec) GetCleanupSubscription 

func (x *SourceSpec) GetCleanupSubscription() bool

func (*SourceSpec) GetConfigs 

func (x *SourceSpec) GetConfigs() string

func (*SourceSpec) GetInputSpecs 

func (x *SourceSpec) GetInputSpecs() map[string]*ConsumerSpec

func (*SourceSpec) GetNegativeAckRedeliveryDelayMs 

func (x *SourceSpec) GetNegativeAckRedeliveryDelayMs() uint64

func (*SourceSpec) GetSkipToLatest added in v0.14.0 

func (x *SourceSpec) GetSkipToLatest() bool

func (*SourceSpec) GetSubscriptionName 

func (x *SourceSpec) GetSubscriptionName() string

func (*SourceSpec) GetSubscriptionPosition 

func (x *SourceSpec) GetSubscriptionPosition() SubscriptionPosition

func (*SourceSpec) GetSubscriptionType 

func (x *SourceSpec) GetSubscriptionType() SubscriptionType

func (*SourceSpec) GetTimeoutMs 

func (x *SourceSpec) GetTimeoutMs() uint64

func (*SourceSpec) GetTopicsPattern deprecated 

func (x *SourceSpec) GetTopicsPattern() string

Deprecated: Do not use.

func (*SourceSpec) GetTopicsToSerDeClassName deprecated 

func (x *SourceSpec) GetTopicsToSerDeClassName() map[string]string

Deprecated: Do not use.

func (*SourceSpec) GetTypeClassName 

func (x *SourceSpec) GetTypeClassName() string

func (*SourceSpec) ProtoMessage 

func (*SourceSpec) ProtoMessage()

func (*SourceSpec) ProtoReflect 

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

func (*SourceSpec) Reset 

func (x *SourceSpec) Reset()

func (*SourceSpec) String 

func (x *SourceSpec) String() string

type SubscriptionPosition 

type SubscriptionPosition int32
const (
	SubscriptionPosition_LATEST   SubscriptionPosition = 0
	SubscriptionPosition_EARLIEST SubscriptionPosition = 1
)

func (SubscriptionPosition) Descriptor 

func (SubscriptionPosition) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionPosition) Enum 

func (x SubscriptionPosition) Enum() *SubscriptionPosition

func (SubscriptionPosition) EnumDescriptor deprecated 

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

Deprecated: Use SubscriptionPosition.Descriptor instead.

func (SubscriptionPosition) Number 

func (x SubscriptionPosition) Number() protoreflect.EnumNumber

func (SubscriptionPosition) String 

func (x SubscriptionPosition) String() string

func (SubscriptionPosition) Type 

func (SubscriptionPosition) Type() protoreflect.EnumType

type SubscriptionType 

type SubscriptionType int32
const (
	SubscriptionType_SHARED     SubscriptionType = 0
	SubscriptionType_FAILOVER   SubscriptionType = 1
	SubscriptionType_KEY_SHARED SubscriptionType = 2
)

func (SubscriptionType) Descriptor 

func (SubscriptionType) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionType) Enum 

func (x SubscriptionType) Enum() *SubscriptionType

func (SubscriptionType) EnumDescriptor deprecated 

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

Deprecated: Use SubscriptionType.Descriptor instead.

func (SubscriptionType) Number 

func (x SubscriptionType) Number() protoreflect.EnumNumber

func (SubscriptionType) String 

func (x SubscriptionType) String() string

func (SubscriptionType) Type 

func (SubscriptionType) Type() protoreflect.EnumType

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.