api

package
v0.0.0-...-2584677 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2023 License: Apache-2.0, BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Overview

Package api provides the protocol buffer messages that Pulsar uses for the client/broker wire protocol. See "Pulsar binary protocol specification" for more information. https://pulsar.incubator.apache.org/docs/latest/project/BinaryProtocol/

The protocol definition files are part of the main Pulsar source, located within the Pulsar repository at: https://github.com/apache/pulsar/tree/master/pulsar-functions/proto/src/main/proto

The generated Go code was created from the source Pulsar files at git: 

tag:      v2.7.0-a55a405c7-741-gcb6617fa02-18-g31f7d70bd4-40-g331ca7c684-16-g956328d84e-3-g21a3a3b537-2-g73e0dbd4df-350-gbd1db1b708-15-g0d52d0b1ca-108-gefacf71f41-27-g9afc59f21c-9-ge4b4627890-19-g510ecfa164-113-g7a89212afa-851-g9f105d0d871
revision: 9f105d0d8716d7650299f43163c1f4ef2a5a819d

Files generated by the protoc-gen-go program should not be modified.

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 (
	ServiceRequest_ServiceRequestType_name = map[int32]string{
		0: "UPDATE",
		1: "DELETE",
		2: "INITIALIZE",
	}
	ServiceRequest_ServiceRequestType_value = map[string]int32{
		"UPDATE":     0,
		"DELETE":     1,
		"INITIALIZE": 2,
	}
)

Enum value maps for ServiceRequest_ServiceRequestType.

View Source 
var File_Function_proto protoreflect.FileDescriptor
View Source 
var File_InstanceCommunication_proto protoreflect.FileDescriptor
View Source 
var File_Request_proto protoreflect.FileDescriptor

Functions

func RegisterInstanceControlServer 

func RegisterInstanceControlServer(s *grpc.Server, srv InstanceControlServer)

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 

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 

func (CompressionType) Descriptor() protoreflect.EnumDescriptor

func (CompressionType) Enum 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated 

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

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Number 

func (x CompressionType) Number() protoreflect.EnumNumber

func (CompressionType) String 

func (x CompressionType) String() string

func (CompressionType) Type 

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 

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 FunctionStatus 

type FunctionStatus struct {
	Running          bool   `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	FailureException string `protobuf:"bytes,2,opt,name=failureException,proto3" json:"failureException,omitempty"`
	NumRestarts      int64  `protobuf:"varint,3,opt,name=numRestarts,proto3" json:"numRestarts,omitempty"`
	// int64 numProcessed = 4;
	NumReceived              int64                                  `protobuf:"varint,17,opt,name=numReceived,proto3" json:"numReceived,omitempty"`
	NumSuccessfullyProcessed int64                                  `protobuf:"varint,5,opt,name=numSuccessfullyProcessed,proto3" json:"numSuccessfullyProcessed,omitempty"`
	NumUserExceptions        int64                                  `protobuf:"varint,6,opt,name=numUserExceptions,proto3" json:"numUserExceptions,omitempty"`
	LatestUserExceptions     []*FunctionStatus_ExceptionInformation `protobuf:"bytes,7,rep,name=latestUserExceptions,proto3" json:"latestUserExceptions,omitempty"`
	NumSystemExceptions      int64                                  `protobuf:"varint,8,opt,name=numSystemExceptions,proto3" json:"numSystemExceptions,omitempty"`
	LatestSystemExceptions   []*FunctionStatus_ExceptionInformation `protobuf:"bytes,9,rep,name=latestSystemExceptions,proto3" json:"latestSystemExceptions,omitempty"`
	NumSourceExceptions      int64                                  `protobuf:"varint,18,opt,name=numSourceExceptions,proto3" json:"numSourceExceptions,omitempty"`
	LatestSourceExceptions   []*FunctionStatus_ExceptionInformation `protobuf:"bytes,19,rep,name=latestSourceExceptions,proto3" json:"latestSourceExceptions,omitempty"`
	NumSinkExceptions        int64                                  `protobuf:"varint,20,opt,name=numSinkExceptions,proto3" json:"numSinkExceptions,omitempty"`
	LatestSinkExceptions     []*FunctionStatus_ExceptionInformation `protobuf:"bytes,21,rep,name=latestSinkExceptions,proto3" json:"latestSinkExceptions,omitempty"`
	// map from topic name to number of deserialization exceptions
	//    map<string, int64> deserializationExceptions = 10;
	// number of serialization exceptions on the output
	//    int64 serializationExceptions = 11;
	// average latency
	AverageLatency float64 `protobuf:"fixed64,12,opt,name=averageLatency,proto3" json:"averageLatency,omitempty"`
	// When was the last time the function was invoked.
	// expressed in ms since epoch
	LastInvocationTime int64  `protobuf:"varint,13,opt,name=lastInvocationTime,proto3" json:"lastInvocationTime,omitempty"`
	InstanceId         string `protobuf:"bytes,14,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	//    MetricsData metrics = 15 [deprecated=true];
	// owner of function-instance
	WorkerId string `protobuf:"bytes,16,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionStatus) Descriptor deprecated 

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

Deprecated: Use FunctionStatus.ProtoReflect.Descriptor instead.

func (*FunctionStatus) GetAverageLatency 

func (x *FunctionStatus) GetAverageLatency() float64

func (*FunctionStatus) GetFailureException 

func (x *FunctionStatus) GetFailureException() string

func (*FunctionStatus) GetInstanceId 

func (x *FunctionStatus) GetInstanceId() string

func (*FunctionStatus) GetLastInvocationTime 

func (x *FunctionStatus) GetLastInvocationTime() int64

func (*FunctionStatus) GetLatestSinkExceptions 

func (x *FunctionStatus) GetLatestSinkExceptions() []*FunctionStatus_ExceptionInformation

func (*FunctionStatus) GetLatestSourceExceptions 

func (x *FunctionStatus) GetLatestSourceExceptions() []*FunctionStatus_ExceptionInformation

func (*FunctionStatus) GetLatestSystemExceptions 

func (x *FunctionStatus) GetLatestSystemExceptions() []*FunctionStatus_ExceptionInformation

func (*FunctionStatus) GetLatestUserExceptions 

func (x *FunctionStatus) GetLatestUserExceptions() []*FunctionStatus_ExceptionInformation

func (*FunctionStatus) GetNumReceived 

func (x *FunctionStatus) GetNumReceived() int64

func (*FunctionStatus) GetNumRestarts 

func (x *FunctionStatus) GetNumRestarts() int64

func (*FunctionStatus) GetNumSinkExceptions 

func (x *FunctionStatus) GetNumSinkExceptions() int64

func (*FunctionStatus) GetNumSourceExceptions 

func (x *FunctionStatus) GetNumSourceExceptions() int64

func (*FunctionStatus) GetNumSuccessfullyProcessed 

func (x *FunctionStatus) GetNumSuccessfullyProcessed() int64

func (*FunctionStatus) GetNumSystemExceptions 

func (x *FunctionStatus) GetNumSystemExceptions() int64

func (*FunctionStatus) GetNumUserExceptions 

func (x *FunctionStatus) GetNumUserExceptions() int64

func (*FunctionStatus) GetRunning 

func (x *FunctionStatus) GetRunning() bool

func (*FunctionStatus) GetWorkerId 

func (x *FunctionStatus) GetWorkerId() string

func (*FunctionStatus) ProtoMessage 

func (*FunctionStatus) ProtoMessage()

func (*FunctionStatus) ProtoReflect 

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

func (*FunctionStatus) Reset 

func (x *FunctionStatus) Reset()

func (*FunctionStatus) String 

func (x *FunctionStatus) String() string

type FunctionStatusList 

type FunctionStatusList struct {
	Error              string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	FunctionStatusList []*FunctionStatus `protobuf:"bytes,1,rep,name=functionStatusList,proto3" json:"functionStatusList,omitempty"`
	// contains filtered or unexported fields
}

Deprecated

func (*FunctionStatusList) Descriptor deprecated 

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

Deprecated: Use FunctionStatusList.ProtoReflect.Descriptor instead.

func (*FunctionStatusList) GetError 

func (x *FunctionStatusList) GetError() string

func (*FunctionStatusList) GetFunctionStatusList 

func (x *FunctionStatusList) GetFunctionStatusList() []*FunctionStatus

func (*FunctionStatusList) ProtoMessage 

func (*FunctionStatusList) ProtoMessage()

func (*FunctionStatusList) ProtoReflect 

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

func (*FunctionStatusList) Reset 

func (x *FunctionStatusList) Reset()

func (*FunctionStatusList) String 

func (x *FunctionStatusList) String() string

type FunctionStatus_ExceptionInformation 

type FunctionStatus_ExceptionInformation struct {
	ExceptionString string `protobuf:"bytes,1,opt,name=exceptionString,proto3" json:"exceptionString,omitempty"`
	MsSinceEpoch    int64  `protobuf:"varint,2,opt,name=msSinceEpoch,proto3" json:"msSinceEpoch,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionStatus_ExceptionInformation) Descriptor deprecated 

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

Deprecated: Use FunctionStatus_ExceptionInformation.ProtoReflect.Descriptor instead.

func (*FunctionStatus_ExceptionInformation) GetExceptionString 

func (x *FunctionStatus_ExceptionInformation) GetExceptionString() string

func (*FunctionStatus_ExceptionInformation) GetMsSinceEpoch 

func (x *FunctionStatus_ExceptionInformation) GetMsSinceEpoch() int64

func (*FunctionStatus_ExceptionInformation) ProtoMessage 

func (*FunctionStatus_ExceptionInformation) ProtoMessage()

func (*FunctionStatus_ExceptionInformation) ProtoReflect 

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

func (*FunctionStatus_ExceptionInformation) Reset 

func (x *FunctionStatus_ExceptionInformation) Reset()

func (*FunctionStatus_ExceptionInformation) String 

func (x *FunctionStatus_ExceptionInformation) String() string

type HealthCheckResult 

type HealthCheckResult struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResult) Descriptor deprecated 

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

Deprecated: Use HealthCheckResult.ProtoReflect.Descriptor instead.

func (*HealthCheckResult) GetSuccess 

func (x *HealthCheckResult) GetSuccess() bool

func (*HealthCheckResult) ProtoMessage 

func (*HealthCheckResult) ProtoMessage()

func (*HealthCheckResult) ProtoReflect 

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

func (*HealthCheckResult) Reset 

func (x *HealthCheckResult) Reset()

func (*HealthCheckResult) String 

func (x *HealthCheckResult) String() string

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 InstanceControlClient 

type InstanceControlClient interface {
	GetFunctionStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FunctionStatus, error)
	GetAndResetMetrics(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetricsData, error)
	ResetMetrics(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetMetrics(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetricsData, error)
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResult, error)
}

InstanceControlClient is the client API for InstanceControl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInstanceControlClient 

func NewInstanceControlClient(cc grpc.ClientConnInterface) InstanceControlClient

type InstanceControlServer 

type InstanceControlServer interface {
	GetFunctionStatus(context.Context, *emptypb.Empty) (*FunctionStatus, error)
	GetAndResetMetrics(context.Context, *emptypb.Empty) (*MetricsData, error)
	ResetMetrics(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetMetrics(context.Context, *emptypb.Empty) (*MetricsData, error)
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResult, error)
}

InstanceControlServer is the server API for InstanceControl service.

type Metrics 

type Metrics struct {
	Metrics []*Metrics_InstanceMetrics `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetMetrics 

func (x *Metrics) GetMetrics() []*Metrics_InstanceMetrics

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type MetricsData 

type MetricsData struct {

	// Total number of records function received from source
	ReceivedTotal      int64 `protobuf:"varint,2,opt,name=receivedTotal,proto3" json:"receivedTotal,omitempty"`
	ReceivedTotal_1Min int64 `protobuf:"varint,10,opt,name=receivedTotal_1min,json=receivedTotal1min,proto3" json:"receivedTotal_1min,omitempty"`
	// Total number of records successfully processed by user function
	ProcessedSuccessfullyTotal      int64 `protobuf:"varint,4,opt,name=processedSuccessfullyTotal,proto3" json:"processedSuccessfullyTotal,omitempty"`
	ProcessedSuccessfullyTotal_1Min int64 `` /* 153-byte string literal not displayed */
	// Total number of system exceptions thrown
	SystemExceptionsTotal      int64 `protobuf:"varint,5,opt,name=systemExceptionsTotal,proto3" json:"systemExceptionsTotal,omitempty"`
	SystemExceptionsTotal_1Min int64 `` /* 138-byte string literal not displayed */
	// Total number of user exceptions thrown
	UserExceptionsTotal      int64 `protobuf:"varint,6,opt,name=userExceptionsTotal,proto3" json:"userExceptionsTotal,omitempty"`
	UserExceptionsTotal_1Min int64 `` /* 132-byte string literal not displayed */
	// Average process latency for function
	AvgProcessLatency      float64 `protobuf:"fixed64,7,opt,name=avgProcessLatency,proto3" json:"avgProcessLatency,omitempty"`
	AvgProcessLatency_1Min float64 `` /* 127-byte string literal not displayed */
	// Timestamp of when the function was last invoked
	LastInvocation int64 `protobuf:"varint,8,opt,name=lastInvocation,proto3" json:"lastInvocation,omitempty"`
	// User defined metrics
	UserMetrics map[string]float64 `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetricsData) Descriptor deprecated 

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

Deprecated: Use MetricsData.ProtoReflect.Descriptor instead.

func (*MetricsData) GetAvgProcessLatency 

func (x *MetricsData) GetAvgProcessLatency() float64

func (*MetricsData) GetAvgProcessLatency_1Min 

func (x *MetricsData) GetAvgProcessLatency_1Min() float64

func (*MetricsData) GetLastInvocation 

func (x *MetricsData) GetLastInvocation() int64

func (*MetricsData) GetProcessedSuccessfullyTotal 

func (x *MetricsData) GetProcessedSuccessfullyTotal() int64

func (*MetricsData) GetProcessedSuccessfullyTotal_1Min 

func (x *MetricsData) GetProcessedSuccessfullyTotal_1Min() int64

func (*MetricsData) GetReceivedTotal 

func (x *MetricsData) GetReceivedTotal() int64

func (*MetricsData) GetReceivedTotal_1Min 

func (x *MetricsData) GetReceivedTotal_1Min() int64

func (*MetricsData) GetSystemExceptionsTotal 

func (x *MetricsData) GetSystemExceptionsTotal() int64

func (*MetricsData) GetSystemExceptionsTotal_1Min 

func (x *MetricsData) GetSystemExceptionsTotal_1Min() int64

func (*MetricsData) GetUserExceptionsTotal 

func (x *MetricsData) GetUserExceptionsTotal() int64

func (*MetricsData) GetUserExceptionsTotal_1Min 

func (x *MetricsData) GetUserExceptionsTotal_1Min() int64

func (*MetricsData) GetUserMetrics 

func (x *MetricsData) GetUserMetrics() map[string]float64

func (*MetricsData) ProtoMessage 

func (*MetricsData) ProtoMessage()

func (*MetricsData) ProtoReflect 

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

func (*MetricsData) Reset 

func (x *MetricsData) Reset()

func (*MetricsData) String 

func (x *MetricsData) String() string

type Metrics_InstanceMetrics 

type Metrics_InstanceMetrics struct {
	Name        string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InstanceId  int32        `protobuf:"varint,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	MetricsData *MetricsData `protobuf:"bytes,3,opt,name=metricsData,proto3" json:"metricsData,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics_InstanceMetrics) Descriptor deprecated 

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

Deprecated: Use Metrics_InstanceMetrics.ProtoReflect.Descriptor instead.

func (*Metrics_InstanceMetrics) GetInstanceId 

func (x *Metrics_InstanceMetrics) GetInstanceId() int32

func (*Metrics_InstanceMetrics) GetMetricsData 

func (x *Metrics_InstanceMetrics) GetMetricsData() *MetricsData

func (*Metrics_InstanceMetrics) GetName 

func (x *Metrics_InstanceMetrics) GetName() string

func (*Metrics_InstanceMetrics) ProtoMessage 

func (*Metrics_InstanceMetrics) ProtoMessage()

func (*Metrics_InstanceMetrics) ProtoReflect 

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

func (*Metrics_InstanceMetrics) Reset 

func (x *Metrics_InstanceMetrics) Reset()

func (*Metrics_InstanceMetrics) String 

func (x *Metrics_InstanceMetrics) 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 

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 ServiceRequest 

type ServiceRequest struct {
	ServiceRequestType ServiceRequest_ServiceRequestType `` /* 135-byte string literal not displayed */
	RequestId          string                            `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	FunctionMetaData   *FunctionMetaData                 `protobuf:"bytes,3,opt,name=functionMetaData,proto3" json:"functionMetaData,omitempty"`
	WorkerId           string                            `protobuf:"bytes,4,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceRequest) Descriptor deprecated 

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

Deprecated: Use ServiceRequest.ProtoReflect.Descriptor instead.

func (*ServiceRequest) GetFunctionMetaData 

func (x *ServiceRequest) GetFunctionMetaData() *FunctionMetaData

func (*ServiceRequest) GetRequestId 

func (x *ServiceRequest) GetRequestId() string

func (*ServiceRequest) GetServiceRequestType 

func (x *ServiceRequest) GetServiceRequestType() ServiceRequest_ServiceRequestType

func (*ServiceRequest) GetWorkerId 

func (x *ServiceRequest) GetWorkerId() string

func (*ServiceRequest) ProtoMessage 

func (*ServiceRequest) ProtoMessage()

func (*ServiceRequest) ProtoReflect 

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

func (*ServiceRequest) Reset 

func (x *ServiceRequest) Reset()

func (*ServiceRequest) String 

func (x *ServiceRequest) String() string

type ServiceRequest_ServiceRequestType 

type ServiceRequest_ServiceRequestType int32
const (
	ServiceRequest_UPDATE     ServiceRequest_ServiceRequestType = 0
	ServiceRequest_DELETE     ServiceRequest_ServiceRequestType = 1
	ServiceRequest_INITIALIZE ServiceRequest_ServiceRequestType = 2
)

func (ServiceRequest_ServiceRequestType) Descriptor 

func (ServiceRequest_ServiceRequestType) Descriptor() protoreflect.EnumDescriptor

func (ServiceRequest_ServiceRequestType) Enum 

func (x ServiceRequest_ServiceRequestType) Enum() *ServiceRequest_ServiceRequestType

func (ServiceRequest_ServiceRequestType) EnumDescriptor deprecated 

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

Deprecated: Use ServiceRequest_ServiceRequestType.Descriptor instead.

func (ServiceRequest_ServiceRequestType) Number 

func (x ServiceRequest_ServiceRequestType) Number() protoreflect.EnumNumber

func (ServiceRequest_ServiceRequestType) String 

func (x ServiceRequest_ServiceRequestType) String() string

func (ServiceRequest_ServiceRequestType) Type 

func (ServiceRequest_ServiceRequestType) Type() protoreflect.EnumType

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 

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

type UnimplementedInstanceControlServer 

type UnimplementedInstanceControlServer struct {
}

UnimplementedInstanceControlServer can be embedded to have forward compatible implementations.

func (*UnimplementedInstanceControlServer) GetAndResetMetrics 

func (*UnimplementedInstanceControlServer) GetAndResetMetrics(context.Context, *emptypb.Empty) (*MetricsData, error)

func (*UnimplementedInstanceControlServer) GetFunctionStatus 

func (*UnimplementedInstanceControlServer) GetFunctionStatus(context.Context, *emptypb.Empty) (*FunctionStatus, error)

func (*UnimplementedInstanceControlServer) GetMetrics 

func (*UnimplementedInstanceControlServer) GetMetrics(context.Context, *emptypb.Empty) (*MetricsData, error)

func (*UnimplementedInstanceControlServer) HealthCheck 

func (*UnimplementedInstanceControlServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResult, error)

func (*UnimplementedInstanceControlServer) ResetMetrics 

func (*UnimplementedInstanceControlServer) ResetMetrics(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Source Files

View all Source files

Directories

Path Synopsis
Package bookkeeper provides the protocol buffer messages that Bookkeeper uses for the stream API.
 Package bookkeeper provides the protocol buffer messages that Bookkeeper uses for the stream API.
cluster
common
kv
kv/rpc
kv/store
storage
stream

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.