Documentation ¶
Index ¶
- Variables
- type AKSKCredential
- func (*AKSKCredential) Descriptor() ([]byte, []int)deprecated
- func (x *AKSKCredential) GetAccessKeyId() string
- func (x *AKSKCredential) GetSecretAccessKey() string
- func (*AKSKCredential) ProtoMessage()
- func (x *AKSKCredential) ProtoReflect() protoreflect.Message
- func (x *AKSKCredential) Reset()
- func (x *AKSKCredential) String() string
- type Action
- type Block
- type CompressAlgorithm
- func (CompressAlgorithm) Descriptor() protoreflect.EnumDescriptor
- func (x CompressAlgorithm) Enum() *CompressAlgorithm
- func (CompressAlgorithm) EnumDescriptor() ([]byte, []int)deprecated
- func (x CompressAlgorithm) Number() protoreflect.EnumNumber
- func (x CompressAlgorithm) String() string
- func (CompressAlgorithm) Type() protoreflect.EnumType
- type Eventbus
- func (*Eventbus) Descriptor() ([]byte, []int)deprecated
- func (x *Eventbus) GetCreatedAt() int64
- func (x *Eventbus) GetDescription() string
- func (x *Eventbus) GetId() uint64
- func (x *Eventbus) GetLogNumber() int32
- func (x *Eventbus) GetLogs() []*Eventlog
- func (x *Eventbus) GetName() string
- func (x *Eventbus) GetNamespaceId() uint64
- func (x *Eventbus) GetUpdatedAt() int64
- func (*Eventbus) ProtoMessage()
- func (x *Eventbus) ProtoReflect() protoreflect.Message
- func (x *Eventbus) Reset()
- func (x *Eventbus) String() string
- type Eventlog
- func (*Eventlog) Descriptor() ([]byte, []int)deprecated
- func (x *Eventlog) GetCurrentSegmentNumbers() int32
- func (x *Eventlog) GetEventbusId() uint64
- func (x *Eventlog) GetEventlogId() uint64
- func (x *Eventlog) GetServerAddress() []string
- func (*Eventlog) ProtoMessage()
- func (x *Eventlog) ProtoReflect() protoreflect.Message
- func (x *Eventlog) Reset()
- func (x *Eventlog) String() string
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetAll() []*Filter
- func (x *Filter) GetAny() []*Filter
- func (x *Filter) GetCel() string
- func (x *Filter) GetExact() map[string]string
- func (x *Filter) GetNot() *Filter
- func (x *Filter) GetPrefix() map[string]string
- func (x *Filter) GetSql() string
- func (x *Filter) GetSuffix() map[string]string
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type GCloudCredential
- type Namespace
- func (*Namespace) Descriptor() ([]byte, []int)deprecated
- func (x *Namespace) GetCreatedAt() int64
- func (x *Namespace) GetDescription() string
- func (x *Namespace) GetId() uint64
- func (x *Namespace) GetName() string
- func (x *Namespace) GetUpdatedAt() int64
- func (*Namespace) ProtoMessage()
- func (x *Namespace) ProtoReflect() protoreflect.Message
- func (x *Namespace) Reset()
- func (x *Namespace) String() string
- type OffsetInfo
- type PlainCredential
- func (*PlainCredential) Descriptor() ([]byte, []int)deprecated
- func (x *PlainCredential) GetIdentifier() string
- func (x *PlainCredential) GetSecret() string
- func (*PlainCredential) ProtoMessage()
- func (x *PlainCredential) ProtoReflect() protoreflect.Message
- func (x *PlainCredential) Reset()
- func (x *PlainCredential) String() string
- type Protocol
- type ProtocolSetting
- type ResourceRole
- func (*ResourceRole) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRole) GetBuiltIn() bool
- func (x *ResourceRole) GetCreatedAt() int64
- func (x *ResourceRole) GetResourceId() uint64
- func (x *ResourceRole) GetResourceKind() string
- func (x *ResourceRole) GetRoleName() string
- func (x *ResourceRole) GetUserIdentifier() string
- func (*ResourceRole) ProtoMessage()
- func (x *ResourceRole) ProtoReflect() protoreflect.Message
- func (x *ResourceRole) Reset()
- func (x *ResourceRole) String() string
- type Segment
- func (*Segment) Descriptor() ([]byte, []int)deprecated
- func (x *Segment) GetCapacity() int64
- func (x *Segment) GetCompressed() CompressAlgorithm
- func (x *Segment) GetEndOffsetInLog() int64
- func (x *Segment) GetEventlogId() uint64
- func (x *Segment) GetFirstEventBornAtByUnixMs() int64
- func (x *Segment) GetId() uint64
- func (x *Segment) GetLastEventBornAtByUnixMs() int64
- func (x *Segment) GetLeaderBlockId() uint64
- func (x *Segment) GetNextSegmentId() uint64
- func (x *Segment) GetNumberEventStored() int32
- func (x *Segment) GetPreviousSegmentId() uint64
- func (x *Segment) GetReplicas() map[uint64]*Block
- func (x *Segment) GetSize() int64
- func (x *Segment) GetStartOffsetInLog() int64
- func (x *Segment) GetState() string
- func (*Segment) ProtoMessage()
- func (x *Segment) ProtoReflect() protoreflect.Message
- func (x *Segment) Reset()
- func (x *Segment) String() string
- type SegmentHealthInfo
- func (*SegmentHealthInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SegmentHealthInfo) GetCapacity() int64
- func (x *SegmentHealthInfo) GetEventNumber() int32
- func (x *SegmentHealthInfo) GetEventlogId() uint64
- func (x *SegmentHealthInfo) GetFirstEventBornTime() int64
- func (x *SegmentHealthInfo) GetId() uint64
- func (x *SegmentHealthInfo) GetIsFull() bool
- func (x *SegmentHealthInfo) GetLastEventBornTime() int64
- func (x *SegmentHealthInfo) GetLeader() uint64
- func (x *SegmentHealthInfo) GetSerializationVersion() int32
- func (x *SegmentHealthInfo) GetSize() int64
- func (x *SegmentHealthInfo) GetTerm() uint64
- func (*SegmentHealthInfo) ProtoMessage()
- func (x *SegmentHealthInfo) ProtoReflect() protoreflect.Message
- func (x *SegmentHealthInfo) Reset()
- func (x *SegmentHealthInfo) String() string
- type SinkCredential
- func (*SinkCredential) Descriptor() ([]byte, []int)deprecated
- func (x *SinkCredential) GetAws() *AKSKCredential
- func (m *SinkCredential) GetCredential() isSinkCredential_Credential
- func (x *SinkCredential) GetCredentialType() SinkCredential_CredentialType
- func (x *SinkCredential) GetGcloud() *GCloudCredential
- func (x *SinkCredential) GetPlain() *PlainCredential
- func (*SinkCredential) ProtoMessage()
- func (x *SinkCredential) ProtoReflect() protoreflect.Message
- func (x *SinkCredential) Reset()
- func (x *SinkCredential) String() string
- type SinkCredential_Aws
- type SinkCredential_CredentialType
- func (SinkCredential_CredentialType) Descriptor() protoreflect.EnumDescriptor
- func (x SinkCredential_CredentialType) Enum() *SinkCredential_CredentialType
- func (SinkCredential_CredentialType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SinkCredential_CredentialType) Number() protoreflect.EnumNumber
- func (x SinkCredential_CredentialType) String() string
- func (SinkCredential_CredentialType) Type() protoreflect.EnumType
- type SinkCredential_Gcloud
- type SinkCredential_Plain
- type StorageTier
- func (StorageTier) Descriptor() protoreflect.EnumDescriptor
- func (x StorageTier) Enum() *StorageTier
- func (StorageTier) EnumDescriptor() ([]byte, []int)deprecated
- func (x StorageTier) Number() protoreflect.EnumNumber
- func (x StorageTier) String() string
- func (StorageTier) Type() protoreflect.EnumType
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)deprecated
- func (x *Subscription) GetConfig() *SubscriptionConfig
- func (x *Subscription) GetCreatedAt() int64
- func (x *Subscription) GetDescription() string
- func (x *Subscription) GetDisable() bool
- func (x *Subscription) GetEventbusId() uint64
- func (x *Subscription) GetFilters() []*Filter
- func (x *Subscription) GetId() uint64
- func (x *Subscription) GetName() string
- func (x *Subscription) GetNamespaceId() uint64
- func (x *Subscription) GetOffsets() []*OffsetInfo
- func (x *Subscription) GetProtocol() Protocol
- func (x *Subscription) GetProtocolSettings() *ProtocolSetting
- func (x *Subscription) GetSink() string
- func (x *Subscription) GetSinkCredential() *SinkCredential
- func (x *Subscription) GetSource() string
- func (x *Subscription) GetTransformer() *Transformer
- func (x *Subscription) GetTypes() []string
- func (x *Subscription) GetUpdatedAt() int64
- func (*Subscription) ProtoMessage()
- func (x *Subscription) ProtoReflect() protoreflect.Message
- func (x *Subscription) Reset()
- func (x *Subscription) String() string
- type SubscriptionConfig
- func (*SubscriptionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionConfig) GetDeliveryTimeout() uint32
- func (x *SubscriptionConfig) GetDisableDeadLetter() bool
- func (x *SubscriptionConfig) GetMaxRetryAttempts() uint32
- func (x *SubscriptionConfig) GetOffsetTimestamp() uint64
- func (x *SubscriptionConfig) GetOffsetType() SubscriptionConfig_OffsetType
- func (x *SubscriptionConfig) GetOrderedEvent() bool
- func (x *SubscriptionConfig) GetRateLimit() uint32
- func (*SubscriptionConfig) ProtoMessage()
- func (x *SubscriptionConfig) ProtoReflect() protoreflect.Message
- func (x *SubscriptionConfig) Reset()
- func (x *SubscriptionConfig) String() string
- type SubscriptionConfig_OffsetType
- func (SubscriptionConfig_OffsetType) Descriptor() protoreflect.EnumDescriptor
- func (x SubscriptionConfig_OffsetType) Enum() *SubscriptionConfig_OffsetType
- func (SubscriptionConfig_OffsetType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscriptionConfig_OffsetType) Number() protoreflect.EnumNumber
- func (x SubscriptionConfig_OffsetType) String() string
- func (SubscriptionConfig_OffsetType) Type() protoreflect.EnumType
- type SubscriptionInfo
- func (*SubscriptionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionInfo) GetOffsets() []*OffsetInfo
- func (x *SubscriptionInfo) GetSubscriptionId() uint64
- func (*SubscriptionInfo) ProtoMessage()
- func (x *SubscriptionInfo) ProtoReflect() protoreflect.Message
- func (x *SubscriptionInfo) Reset()
- func (x *SubscriptionInfo) String() string
- type TemplateType
- func (TemplateType) Descriptor() protoreflect.EnumDescriptor
- func (x TemplateType) Enum() *TemplateType
- func (TemplateType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TemplateType) Number() protoreflect.EnumNumber
- func (x TemplateType) String() string
- func (TemplateType) Type() protoreflect.EnumType
- type Token
- func (*Token) Descriptor() ([]byte, []int)deprecated
- func (x *Token) GetCreatedAt() int64
- func (x *Token) GetId() uint64
- func (x *Token) GetToken() string
- func (x *Token) GetUpdatedAt() int64
- func (x *Token) GetUserIdentifier() string
- func (*Token) ProtoMessage()
- func (x *Token) ProtoReflect() protoreflect.Message
- func (x *Token) Reset()
- func (x *Token) String() string
- type Transformer
- func (*Transformer) Descriptor() ([]byte, []int)deprecated
- func (x *Transformer) GetDefine() map[string]string
- func (x *Transformer) GetPipeline() []*Action
- func (x *Transformer) GetTemplate() string
- func (x *Transformer) GetTemplateType() TemplateType
- func (*Transformer) ProtoMessage()
- func (x *Transformer) ProtoReflect() protoreflect.Message
- func (x *Transformer) Reset()
- func (x *Transformer) String() string
- type User
- func (*User) Descriptor() ([]byte, []int)deprecated
- func (x *User) GetCreatedAt() int64
- func (x *User) GetDescription() string
- func (x *User) GetIdentifier() string
- func (x *User) GetUpdatedAt() int64
- func (*User) ProtoMessage()
- func (x *User) ProtoReflect() protoreflect.Message
- func (x *User) Reset()
- func (x *User) String() string
- type UserRole
- func (*UserRole) Descriptor() ([]byte, []int)deprecated
- func (x *UserRole) GetBuiltIn() bool
- func (x *UserRole) GetCreatedAt() int64
- func (x *UserRole) GetResourceId() uint64
- func (x *UserRole) GetResourceKind() string
- func (x *UserRole) GetRoleName() string
- func (x *UserRole) GetUserIdentifier() string
- func (*UserRole) ProtoMessage()
- func (x *UserRole) ProtoReflect() protoreflect.Message
- func (x *UserRole) Reset()
- func (x *UserRole) String() string
- type VanusResourceName
Constants ¶
This section is empty.
Variables ¶
var ( StorageTier_name = map[int32]string{ 0: "MEMORY", 1: "SSD", 2: "HDD", 3: "S3", } StorageTier_value = map[string]int32{ "MEMORY": 0, "SSD": 1, "HDD": 2, "S3": 3, } )
Enum value maps for StorageTier.
var ( CompressAlgorithm_name = map[int32]string{ 0: "NONE", 1: "LZ4", } CompressAlgorithm_value = map[string]int32{ "NONE": 0, "LZ4": 1, } )
Enum value maps for CompressAlgorithm.
var ( Protocol_name = map[int32]string{ 0: "HTTP", 1: "AWS_LAMBDA", 2: "GCLOUD_FUNCTIONS", 3: "GRPC", } Protocol_value = map[string]int32{ "HTTP": 0, "AWS_LAMBDA": 1, "GCLOUD_FUNCTIONS": 2, "GRPC": 3, } )
Enum value maps for Protocol.
var ( TemplateType_name = map[int32]string{ 0: "TEMPLATE_TYPE_UNSPECIFIED", 1: "TEMPLATE_TYPE_NONE", 2: "TEMPLATE_TYPE_TEXT", 3: "TEMPLATE_TYPE_JSON", } TemplateType_value = map[string]int32{ "TEMPLATE_TYPE_UNSPECIFIED": 0, "TEMPLATE_TYPE_NONE": 1, "TEMPLATE_TYPE_TEXT": 2, "TEMPLATE_TYPE_JSON": 3, } )
Enum value maps for TemplateType.
var ( SinkCredential_CredentialType_name = map[int32]string{ 0: "None", 1: "PLAIN", 2: "AWS", 3: "GCLOUD", } SinkCredential_CredentialType_value = map[string]int32{ "None": 0, "PLAIN": 1, "AWS": 2, "GCLOUD": 3, } )
Enum value maps for SinkCredential_CredentialType.
var ( SubscriptionConfig_OffsetType_name = map[int32]string{ 0: "LATEST", 1: "EARLIEST", 2: "TIMESTAMP", } SubscriptionConfig_OffsetType_value = map[string]int32{ "LATEST": 0, "EARLIEST": 1, "TIMESTAMP": 2, } )
Enum value maps for SubscriptionConfig_OffsetType.
var File_vanus_core_meta_meta_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AKSKCredential ¶
type AKSKCredential struct { AccessKeyId string `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"` SecretAccessKey string `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"` // contains filtered or unexported fields }
func (*AKSKCredential) Descriptor
deprecated
func (*AKSKCredential) Descriptor() ([]byte, []int)
Deprecated: Use AKSKCredential.ProtoReflect.Descriptor instead.
func (*AKSKCredential) GetAccessKeyId ¶
func (x *AKSKCredential) GetAccessKeyId() string
func (*AKSKCredential) GetSecretAccessKey ¶
func (x *AKSKCredential) GetSecretAccessKey() string
func (*AKSKCredential) ProtoMessage ¶
func (*AKSKCredential) ProtoMessage()
func (*AKSKCredential) ProtoReflect ¶
func (x *AKSKCredential) ProtoReflect() protoreflect.Message
func (*AKSKCredential) Reset ¶
func (x *AKSKCredential) Reset()
func (*AKSKCredential) String ¶
func (x *AKSKCredential) String() string
type Action ¶
type Action struct { Command []*structpb.Value `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"` // contains filtered or unexported fields }
func (*Action) Descriptor
deprecated
func (*Action) GetCommand ¶
func (*Action) ProtoMessage ¶
func (*Action) ProtoMessage()
func (*Action) ProtoReflect ¶
func (x *Action) ProtoReflect() protoreflect.Message
type Block ¶
type Block struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"` VolumeID uint64 `protobuf:"varint,3,opt,name=volumeID,proto3" json:"volumeID,omitempty"` // contains filtered or unexported fields }
func (*Block) Descriptor
deprecated
func (*Block) GetEndpoint ¶
func (*Block) GetVolumeID ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) ProtoReflect ¶
func (x *Block) ProtoReflect() protoreflect.Message
type CompressAlgorithm ¶
type CompressAlgorithm int32
const ( CompressAlgorithm_NONE CompressAlgorithm = 0 CompressAlgorithm_LZ4 CompressAlgorithm = 1 )
func (CompressAlgorithm) Descriptor ¶
func (CompressAlgorithm) Descriptor() protoreflect.EnumDescriptor
func (CompressAlgorithm) Enum ¶
func (x CompressAlgorithm) Enum() *CompressAlgorithm
func (CompressAlgorithm) EnumDescriptor
deprecated
func (CompressAlgorithm) EnumDescriptor() ([]byte, []int)
Deprecated: Use CompressAlgorithm.Descriptor instead.
func (CompressAlgorithm) Number ¶
func (x CompressAlgorithm) Number() protoreflect.EnumNumber
func (CompressAlgorithm) String ¶
func (x CompressAlgorithm) String() string
func (CompressAlgorithm) Type ¶
func (CompressAlgorithm) Type() protoreflect.EnumType
type Eventbus ¶
type Eventbus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` LogNumber int32 `protobuf:"varint,2,opt,name=log_number,json=logNumber,proto3" json:"log_number,omitempty"` Logs []*Eventlog `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"` Id uint64 `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` CreatedAt int64 `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` NamespaceId uint64 `protobuf:"varint,8,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // contains filtered or unexported fields }
func (*Eventbus) Descriptor
deprecated
func (*Eventbus) GetCreatedAt ¶
func (*Eventbus) GetDescription ¶
func (*Eventbus) GetLogNumber ¶
func (*Eventbus) GetNamespaceId ¶
func (*Eventbus) GetUpdatedAt ¶
func (*Eventbus) ProtoMessage ¶
func (*Eventbus) ProtoMessage()
func (*Eventbus) ProtoReflect ¶
func (x *Eventbus) ProtoReflect() protoreflect.Message
type Eventlog ¶
type Eventlog struct { EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"` CurrentSegmentNumbers int32 `` /* 127-byte string literal not displayed */ ServerAddress []string `protobuf:"bytes,4,rep,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"` EventbusId uint64 `protobuf:"varint,5,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"` // contains filtered or unexported fields }
func (*Eventlog) Descriptor
deprecated
func (*Eventlog) GetCurrentSegmentNumbers ¶
func (*Eventlog) GetEventbusId ¶
func (*Eventlog) GetEventlogId ¶
func (*Eventlog) GetServerAddress ¶
func (*Eventlog) ProtoMessage ¶
func (*Eventlog) ProtoMessage()
func (*Eventlog) ProtoReflect ¶
func (x *Eventlog) ProtoReflect() protoreflect.Message
type Filter ¶
type Filter struct { Exact map[string]string `` /* 151-byte string literal not displayed */ Prefix map[string]string `` /* 153-byte string literal not displayed */ Suffix map[string]string `` /* 153-byte string literal not displayed */ Not *Filter `protobuf:"bytes,4,opt,name=not,proto3" json:"not,omitempty"` All []*Filter `protobuf:"bytes,5,rep,name=all,proto3" json:"all,omitempty"` Any []*Filter `protobuf:"bytes,6,rep,name=any,proto3" json:"any,omitempty"` Sql string `protobuf:"bytes,7,opt,name=sql,proto3" json:"sql,omitempty"` Cel string `protobuf:"bytes,8,opt,name=cel,proto3" json:"cel,omitempty"` // contains filtered or unexported fields }
func (*Filter) Descriptor
deprecated
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type GCloudCredential ¶
type GCloudCredential struct { CredentialsJson string `protobuf:"bytes,1,opt,name=credentials_json,json=credentialsJson,proto3" json:"credentials_json,omitempty"` // contains filtered or unexported fields }
func (*GCloudCredential) Descriptor
deprecated
func (*GCloudCredential) Descriptor() ([]byte, []int)
Deprecated: Use GCloudCredential.ProtoReflect.Descriptor instead.
func (*GCloudCredential) GetCredentialsJson ¶
func (x *GCloudCredential) GetCredentialsJson() string
func (*GCloudCredential) ProtoMessage ¶
func (*GCloudCredential) ProtoMessage()
func (*GCloudCredential) ProtoReflect ¶
func (x *GCloudCredential) ProtoReflect() protoreflect.Message
func (*GCloudCredential) Reset ¶
func (x *GCloudCredential) Reset()
func (*GCloudCredential) String ¶
func (x *GCloudCredential) String() string
type Namespace ¶
type Namespace struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*Namespace) Descriptor
deprecated
func (*Namespace) GetCreatedAt ¶
func (*Namespace) GetDescription ¶
func (*Namespace) GetUpdatedAt ¶
func (*Namespace) ProtoMessage ¶
func (*Namespace) ProtoMessage()
func (*Namespace) ProtoReflect ¶
func (x *Namespace) ProtoReflect() protoreflect.Message
type OffsetInfo ¶
type OffsetInfo struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"` // contains filtered or unexported fields }
func (*OffsetInfo) Descriptor
deprecated
func (*OffsetInfo) Descriptor() ([]byte, []int)
Deprecated: Use OffsetInfo.ProtoReflect.Descriptor instead.
func (*OffsetInfo) GetEventlogId ¶
func (x *OffsetInfo) GetEventlogId() uint64
func (*OffsetInfo) GetOffset ¶
func (x *OffsetInfo) GetOffset() uint64
func (*OffsetInfo) ProtoMessage ¶
func (*OffsetInfo) ProtoMessage()
func (*OffsetInfo) ProtoReflect ¶
func (x *OffsetInfo) ProtoReflect() protoreflect.Message
func (*OffsetInfo) Reset ¶
func (x *OffsetInfo) Reset()
func (*OffsetInfo) String ¶
func (x *OffsetInfo) String() string
type PlainCredential ¶
type PlainCredential struct { Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` Secret string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*PlainCredential) Descriptor
deprecated
func (*PlainCredential) Descriptor() ([]byte, []int)
Deprecated: Use PlainCredential.ProtoReflect.Descriptor instead.
func (*PlainCredential) GetIdentifier ¶
func (x *PlainCredential) GetIdentifier() string
func (*PlainCredential) GetSecret ¶
func (x *PlainCredential) GetSecret() string
func (*PlainCredential) ProtoMessage ¶
func (*PlainCredential) ProtoMessage()
func (*PlainCredential) ProtoReflect ¶
func (x *PlainCredential) ProtoReflect() protoreflect.Message
func (*PlainCredential) Reset ¶
func (x *PlainCredential) Reset()
func (*PlainCredential) String ¶
func (x *PlainCredential) String() string
type Protocol ¶
type Protocol int32
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) Number ¶
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶
func (Protocol) Type() protoreflect.EnumType
type ProtocolSetting ¶
type ProtocolSetting struct { Headers map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ProtocolSetting) Descriptor
deprecated
func (*ProtocolSetting) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolSetting.ProtoReflect.Descriptor instead.
func (*ProtocolSetting) GetHeaders ¶
func (x *ProtocolSetting) GetHeaders() map[string]string
func (*ProtocolSetting) ProtoMessage ¶
func (*ProtocolSetting) ProtoMessage()
func (*ProtocolSetting) ProtoReflect ¶
func (x *ProtocolSetting) ProtoReflect() protoreflect.Message
func (*ProtocolSetting) Reset ¶
func (x *ProtocolSetting) Reset()
func (*ProtocolSetting) String ¶
func (x *ProtocolSetting) String() string
type ResourceRole ¶
type ResourceRole struct { ResourceId uint64 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceKind string `protobuf:"bytes,2,opt,name=resource_kind,json=resourceKind,proto3" json:"resource_kind,omitempty"` RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"` UserIdentifier string `protobuf:"bytes,4,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"` BuiltIn bool `protobuf:"varint,5,opt,name=built_in,json=builtIn,proto3" json:"built_in,omitempty"` // for custom define role // // string role_id = 6; CreatedAt int64 `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*ResourceRole) Descriptor
deprecated
func (*ResourceRole) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRole.ProtoReflect.Descriptor instead.
func (*ResourceRole) GetBuiltIn ¶
func (x *ResourceRole) GetBuiltIn() bool
func (*ResourceRole) GetCreatedAt ¶
func (x *ResourceRole) GetCreatedAt() int64
func (*ResourceRole) GetResourceId ¶
func (x *ResourceRole) GetResourceId() uint64
func (*ResourceRole) GetResourceKind ¶
func (x *ResourceRole) GetResourceKind() string
func (*ResourceRole) GetRoleName ¶
func (x *ResourceRole) GetRoleName() string
func (*ResourceRole) GetUserIdentifier ¶
func (x *ResourceRole) GetUserIdentifier() string
func (*ResourceRole) ProtoMessage ¶
func (*ResourceRole) ProtoMessage()
func (*ResourceRole) ProtoReflect ¶
func (x *ResourceRole) ProtoReflect() protoreflect.Message
func (*ResourceRole) Reset ¶
func (x *ResourceRole) Reset()
func (*ResourceRole) String ¶
func (x *ResourceRole) String() string
type Segment ¶
type Segment struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` PreviousSegmentId uint64 `protobuf:"varint,2,opt,name=previous_segment_id,json=previousSegmentId,proto3" json:"previous_segment_id,omitempty"` NextSegmentId uint64 `protobuf:"varint,3,opt,name=next_segment_id,json=nextSegmentId,proto3" json:"next_segment_id,omitempty"` EventlogId uint64 `protobuf:"varint,4,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"` StartOffsetInLog int64 `protobuf:"varint,5,opt,name=start_offset_in_log,json=startOffsetInLog,proto3" json:"start_offset_in_log,omitempty"` EndOffsetInLog int64 `protobuf:"varint,6,opt,name=end_offset_in_log,json=endOffsetInLog,proto3" json:"end_offset_in_log,omitempty"` Size int64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"` Capacity int64 `protobuf:"varint,8,opt,name=capacity,proto3" json:"capacity,omitempty"` NumberEventStored int32 `protobuf:"varint,9,opt,name=number_event_stored,json=numberEventStored,proto3" json:"number_event_stored,omitempty"` Compressed CompressAlgorithm `protobuf:"varint,10,opt,name=compressed,proto3,enum=vanus.core.meta.CompressAlgorithm" json:"compressed,omitempty"` State string `protobuf:"bytes,11,opt,name=state,proto3" json:"state,omitempty"` Replicas map[uint64]*Block `` /* 159-byte string literal not displayed */ LeaderBlockId uint64 `protobuf:"varint,13,opt,name=leader_block_id,json=leaderBlockId,proto3" json:"leader_block_id,omitempty"` FirstEventBornAtByUnixMs int64 `` /* 145-byte string literal not displayed */ LastEventBornAtByUnixMs int64 `` /* 142-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Segment) Descriptor
deprecated
func (*Segment) GetCapacity ¶
func (*Segment) GetCompressed ¶
func (x *Segment) GetCompressed() CompressAlgorithm
func (*Segment) GetEndOffsetInLog ¶
func (*Segment) GetEventlogId ¶
func (*Segment) GetFirstEventBornAtByUnixMs ¶
func (*Segment) GetLastEventBornAtByUnixMs ¶
func (*Segment) GetLeaderBlockId ¶
func (*Segment) GetNextSegmentId ¶
func (*Segment) GetNumberEventStored ¶
func (*Segment) GetPreviousSegmentId ¶
func (*Segment) GetReplicas ¶
func (*Segment) GetStartOffsetInLog ¶
func (*Segment) ProtoMessage ¶
func (*Segment) ProtoMessage()
func (*Segment) ProtoReflect ¶
func (x *Segment) ProtoReflect() protoreflect.Message
type SegmentHealthInfo ¶
type SegmentHealthInfo struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"` Capacity int64 `protobuf:"varint,3,opt,name=capacity,proto3" json:"capacity,omitempty"` Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"` EventNumber int32 `protobuf:"varint,5,opt,name=event_number,json=eventNumber,proto3" json:"event_number,omitempty"` SerializationVersion int32 `protobuf:"varint,6,opt,name=serialization_version,json=serializationVersion,proto3" json:"serialization_version,omitempty"` IsFull bool `protobuf:"varint,7,opt,name=is_full,json=isFull,proto3" json:"is_full,omitempty"` Leader uint64 `protobuf:"varint,8,opt,name=leader,proto3" json:"leader,omitempty"` Term uint64 `protobuf:"varint,9,opt,name=term,proto3" json:"term,omitempty"` // Unix timestamp, unit is millisecond FirstEventBornTime int64 `protobuf:"varint,10,opt,name=first_event_born_time,json=firstEventBornTime,proto3" json:"first_event_born_time,omitempty"` // Unix timestamp, unit is millisecond LastEventBornTime int64 `protobuf:"varint,11,opt,name=last_event_born_time,json=lastEventBornTime,proto3" json:"last_event_born_time,omitempty"` // contains filtered or unexported fields }
func (*SegmentHealthInfo) Descriptor
deprecated
func (*SegmentHealthInfo) Descriptor() ([]byte, []int)
Deprecated: Use SegmentHealthInfo.ProtoReflect.Descriptor instead.
func (*SegmentHealthInfo) GetCapacity ¶
func (x *SegmentHealthInfo) GetCapacity() int64
func (*SegmentHealthInfo) GetEventNumber ¶
func (x *SegmentHealthInfo) GetEventNumber() int32
func (*SegmentHealthInfo) GetEventlogId ¶
func (x *SegmentHealthInfo) GetEventlogId() uint64
func (*SegmentHealthInfo) GetFirstEventBornTime ¶
func (x *SegmentHealthInfo) GetFirstEventBornTime() int64
func (*SegmentHealthInfo) GetId ¶
func (x *SegmentHealthInfo) GetId() uint64
func (*SegmentHealthInfo) GetIsFull ¶
func (x *SegmentHealthInfo) GetIsFull() bool
func (*SegmentHealthInfo) GetLastEventBornTime ¶
func (x *SegmentHealthInfo) GetLastEventBornTime() int64
func (*SegmentHealthInfo) GetLeader ¶
func (x *SegmentHealthInfo) GetLeader() uint64
func (*SegmentHealthInfo) GetSerializationVersion ¶
func (x *SegmentHealthInfo) GetSerializationVersion() int32
func (*SegmentHealthInfo) GetSize ¶
func (x *SegmentHealthInfo) GetSize() int64
func (*SegmentHealthInfo) GetTerm ¶
func (x *SegmentHealthInfo) GetTerm() uint64
func (*SegmentHealthInfo) ProtoMessage ¶
func (*SegmentHealthInfo) ProtoMessage()
func (*SegmentHealthInfo) ProtoReflect ¶
func (x *SegmentHealthInfo) ProtoReflect() protoreflect.Message
func (*SegmentHealthInfo) Reset ¶
func (x *SegmentHealthInfo) Reset()
func (*SegmentHealthInfo) String ¶
func (x *SegmentHealthInfo) String() string
type SinkCredential ¶
type SinkCredential struct { CredentialType SinkCredential_CredentialType `` /* 155-byte string literal not displayed */ // Types that are assignable to Credential: // // *SinkCredential_Plain // *SinkCredential_Aws // *SinkCredential_Gcloud Credential isSinkCredential_Credential `protobuf_oneof:"credential"` // contains filtered or unexported fields }
func (*SinkCredential) Descriptor
deprecated
func (*SinkCredential) Descriptor() ([]byte, []int)
Deprecated: Use SinkCredential.ProtoReflect.Descriptor instead.
func (*SinkCredential) GetAws ¶
func (x *SinkCredential) GetAws() *AKSKCredential
func (*SinkCredential) GetCredential ¶
func (m *SinkCredential) GetCredential() isSinkCredential_Credential
func (*SinkCredential) GetCredentialType ¶
func (x *SinkCredential) GetCredentialType() SinkCredential_CredentialType
func (*SinkCredential) GetGcloud ¶
func (x *SinkCredential) GetGcloud() *GCloudCredential
func (*SinkCredential) GetPlain ¶
func (x *SinkCredential) GetPlain() *PlainCredential
func (*SinkCredential) ProtoMessage ¶
func (*SinkCredential) ProtoMessage()
func (*SinkCredential) ProtoReflect ¶
func (x *SinkCredential) ProtoReflect() protoreflect.Message
func (*SinkCredential) Reset ¶
func (x *SinkCredential) Reset()
func (*SinkCredential) String ¶
func (x *SinkCredential) String() string
type SinkCredential_Aws ¶
type SinkCredential_Aws struct {
Aws *AKSKCredential `protobuf:"bytes,3,opt,name=aws,proto3,oneof"`
}
type SinkCredential_CredentialType ¶
type SinkCredential_CredentialType int32
const ( SinkCredential_None SinkCredential_CredentialType = 0 SinkCredential_PLAIN SinkCredential_CredentialType = 1 SinkCredential_AWS SinkCredential_CredentialType = 2 SinkCredential_GCLOUD SinkCredential_CredentialType = 3 )
func (SinkCredential_CredentialType) Descriptor ¶
func (SinkCredential_CredentialType) Descriptor() protoreflect.EnumDescriptor
func (SinkCredential_CredentialType) Enum ¶
func (x SinkCredential_CredentialType) Enum() *SinkCredential_CredentialType
func (SinkCredential_CredentialType) EnumDescriptor
deprecated
func (SinkCredential_CredentialType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SinkCredential_CredentialType.Descriptor instead.
func (SinkCredential_CredentialType) Number ¶
func (x SinkCredential_CredentialType) Number() protoreflect.EnumNumber
func (SinkCredential_CredentialType) String ¶
func (x SinkCredential_CredentialType) String() string
func (SinkCredential_CredentialType) Type ¶
func (SinkCredential_CredentialType) Type() protoreflect.EnumType
type SinkCredential_Gcloud ¶
type SinkCredential_Gcloud struct {
Gcloud *GCloudCredential `protobuf:"bytes,4,opt,name=gcloud,proto3,oneof"`
}
type SinkCredential_Plain ¶
type SinkCredential_Plain struct {
Plain *PlainCredential `protobuf:"bytes,2,opt,name=plain,proto3,oneof"`
}
type StorageTier ¶
type StorageTier int32
const ( StorageTier_MEMORY StorageTier = 0 StorageTier_SSD StorageTier = 1 StorageTier_HDD StorageTier = 2 StorageTier_S3 StorageTier = 3 )
func (StorageTier) Descriptor ¶
func (StorageTier) Descriptor() protoreflect.EnumDescriptor
func (StorageTier) Enum ¶
func (x StorageTier) Enum() *StorageTier
func (StorageTier) EnumDescriptor
deprecated
func (StorageTier) EnumDescriptor() ([]byte, []int)
Deprecated: Use StorageTier.Descriptor instead.
func (StorageTier) Number ¶
func (x StorageTier) Number() protoreflect.EnumNumber
func (StorageTier) String ¶
func (x StorageTier) String() string
func (StorageTier) Type ¶
func (StorageTier) Type() protoreflect.EnumType
type Subscription ¶
type Subscription struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"` Config *SubscriptionConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` Filters []*Filter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"` Sink string `protobuf:"bytes,5,opt,name=sink,proto3" json:"sink,omitempty"` SinkCredential *SinkCredential `protobuf:"bytes,6,opt,name=sink_credential,json=sinkCredential,proto3" json:"sink_credential,omitempty"` Protocol Protocol `protobuf:"varint,7,opt,name=protocol,proto3,enum=vanus.core.meta.Protocol" json:"protocol,omitempty"` ProtocolSettings *ProtocolSetting `protobuf:"bytes,8,opt,name=protocol_settings,json=protocolSettings,proto3" json:"protocol_settings,omitempty"` Transformer *Transformer `protobuf:"bytes,10,opt,name=transformer,proto3" json:"transformer,omitempty"` Name string `protobuf:"bytes,11,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"` Disable bool `protobuf:"varint,13,opt,name=disable,proto3" json:"disable,omitempty"` CreatedAt int64 `protobuf:"varint,14,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,15,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` EventbusId uint64 `protobuf:"varint,16,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"` NamespaceId uint64 `protobuf:"varint,17,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` Id uint64 `protobuf:"varint,100,opt,name=id,proto3" json:"id,omitempty"` Offsets []*OffsetInfo `protobuf:"bytes,101,rep,name=offsets,proto3" json:"offsets,omitempty"` // contains filtered or unexported fields }
func (*Subscription) Descriptor
deprecated
func (*Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
func (*Subscription) GetConfig ¶
func (x *Subscription) GetConfig() *SubscriptionConfig
func (*Subscription) GetCreatedAt ¶
func (x *Subscription) GetCreatedAt() int64
func (*Subscription) GetDescription ¶
func (x *Subscription) GetDescription() string
func (*Subscription) GetDisable ¶
func (x *Subscription) GetDisable() bool
func (*Subscription) GetEventbusId ¶
func (x *Subscription) GetEventbusId() uint64
func (*Subscription) GetFilters ¶
func (x *Subscription) GetFilters() []*Filter
func (*Subscription) GetId ¶
func (x *Subscription) GetId() uint64
func (*Subscription) GetName ¶
func (x *Subscription) GetName() string
func (*Subscription) GetNamespaceId ¶
func (x *Subscription) GetNamespaceId() uint64
func (*Subscription) GetOffsets ¶
func (x *Subscription) GetOffsets() []*OffsetInfo
func (*Subscription) GetProtocol ¶
func (x *Subscription) GetProtocol() Protocol
func (*Subscription) GetProtocolSettings ¶
func (x *Subscription) GetProtocolSettings() *ProtocolSetting
func (*Subscription) GetSink ¶
func (x *Subscription) GetSink() string
func (*Subscription) GetSinkCredential ¶
func (x *Subscription) GetSinkCredential() *SinkCredential
func (*Subscription) GetSource ¶
func (x *Subscription) GetSource() string
func (*Subscription) GetTransformer ¶
func (x *Subscription) GetTransformer() *Transformer
func (*Subscription) GetTypes ¶
func (x *Subscription) GetTypes() []string
func (*Subscription) GetUpdatedAt ¶
func (x *Subscription) GetUpdatedAt() int64
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) ProtoReflect ¶
func (x *Subscription) ProtoReflect() protoreflect.Message
func (*Subscription) Reset ¶
func (x *Subscription) Reset()
func (*Subscription) String ¶
func (x *Subscription) String() string
type SubscriptionConfig ¶
type SubscriptionConfig struct { RateLimit uint32 `protobuf:"varint,1,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"` OffsetType SubscriptionConfig_OffsetType `` /* 143-byte string literal not displayed */ // utc time milliseconds OffsetTimestamp *uint64 `protobuf:"varint,3,opt,name=offset_timestamp,json=offsetTimestamp,proto3,oneof" json:"offset_timestamp,omitempty"` // delivery timeout, unit milliseconds DeliveryTimeout uint32 `protobuf:"varint,4,opt,name=delivery_timeout,json=deliveryTimeout,proto3" json:"delivery_timeout,omitempty"` MaxRetryAttempts *uint32 `protobuf:"varint,5,opt,name=max_retry_attempts,json=maxRetryAttempts,proto3,oneof" json:"max_retry_attempts,omitempty"` DisableDeadLetter bool `protobuf:"varint,6,opt,name=disable_dead_letter,json=disableDeadLetter,proto3" json:"disable_dead_letter,omitempty"` OrderedEvent bool `protobuf:"varint,7,opt,name=ordered_event,json=orderedEvent,proto3" json:"ordered_event,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionConfig) Descriptor
deprecated
func (*SubscriptionConfig) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionConfig.ProtoReflect.Descriptor instead.
func (*SubscriptionConfig) GetDeliveryTimeout ¶
func (x *SubscriptionConfig) GetDeliveryTimeout() uint32
func (*SubscriptionConfig) GetDisableDeadLetter ¶
func (x *SubscriptionConfig) GetDisableDeadLetter() bool
func (*SubscriptionConfig) GetMaxRetryAttempts ¶
func (x *SubscriptionConfig) GetMaxRetryAttempts() uint32
func (*SubscriptionConfig) GetOffsetTimestamp ¶
func (x *SubscriptionConfig) GetOffsetTimestamp() uint64
func (*SubscriptionConfig) GetOffsetType ¶
func (x *SubscriptionConfig) GetOffsetType() SubscriptionConfig_OffsetType
func (*SubscriptionConfig) GetOrderedEvent ¶
func (x *SubscriptionConfig) GetOrderedEvent() bool
func (*SubscriptionConfig) GetRateLimit ¶
func (x *SubscriptionConfig) GetRateLimit() uint32
func (*SubscriptionConfig) ProtoMessage ¶
func (*SubscriptionConfig) ProtoMessage()
func (*SubscriptionConfig) ProtoReflect ¶
func (x *SubscriptionConfig) ProtoReflect() protoreflect.Message
func (*SubscriptionConfig) Reset ¶
func (x *SubscriptionConfig) Reset()
func (*SubscriptionConfig) String ¶
func (x *SubscriptionConfig) String() string
type SubscriptionConfig_OffsetType ¶
type SubscriptionConfig_OffsetType int32
const ( SubscriptionConfig_LATEST SubscriptionConfig_OffsetType = 0 SubscriptionConfig_EARLIEST SubscriptionConfig_OffsetType = 1 SubscriptionConfig_TIMESTAMP SubscriptionConfig_OffsetType = 2 )
func (SubscriptionConfig_OffsetType) Descriptor ¶
func (SubscriptionConfig_OffsetType) Descriptor() protoreflect.EnumDescriptor
func (SubscriptionConfig_OffsetType) Enum ¶
func (x SubscriptionConfig_OffsetType) Enum() *SubscriptionConfig_OffsetType
func (SubscriptionConfig_OffsetType) EnumDescriptor
deprecated
func (SubscriptionConfig_OffsetType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscriptionConfig_OffsetType.Descriptor instead.
func (SubscriptionConfig_OffsetType) Number ¶
func (x SubscriptionConfig_OffsetType) Number() protoreflect.EnumNumber
func (SubscriptionConfig_OffsetType) String ¶
func (x SubscriptionConfig_OffsetType) String() string
func (SubscriptionConfig_OffsetType) Type ¶
func (SubscriptionConfig_OffsetType) Type() protoreflect.EnumType
type SubscriptionInfo ¶
type SubscriptionInfo struct { SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"` Offsets []*OffsetInfo `protobuf:"bytes,2,rep,name=offsets,proto3" json:"offsets,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionInfo) Descriptor
deprecated
func (*SubscriptionInfo) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionInfo.ProtoReflect.Descriptor instead.
func (*SubscriptionInfo) GetOffsets ¶
func (x *SubscriptionInfo) GetOffsets() []*OffsetInfo
func (*SubscriptionInfo) GetSubscriptionId ¶
func (x *SubscriptionInfo) GetSubscriptionId() uint64
func (*SubscriptionInfo) ProtoMessage ¶
func (*SubscriptionInfo) ProtoMessage()
func (*SubscriptionInfo) ProtoReflect ¶
func (x *SubscriptionInfo) ProtoReflect() protoreflect.Message
func (*SubscriptionInfo) Reset ¶
func (x *SubscriptionInfo) Reset()
func (*SubscriptionInfo) String ¶
func (x *SubscriptionInfo) String() string
type TemplateType ¶
type TemplateType int32
const ( TemplateType_TEMPLATE_TYPE_UNSPECIFIED TemplateType = 0 TemplateType_TEMPLATE_TYPE_NONE TemplateType = 1 TemplateType_TEMPLATE_TYPE_TEXT TemplateType = 2 TemplateType_TEMPLATE_TYPE_JSON TemplateType = 3 )
func (TemplateType) Descriptor ¶
func (TemplateType) Descriptor() protoreflect.EnumDescriptor
func (TemplateType) Enum ¶
func (x TemplateType) Enum() *TemplateType
func (TemplateType) EnumDescriptor
deprecated
func (TemplateType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TemplateType.Descriptor instead.
func (TemplateType) Number ¶
func (x TemplateType) Number() protoreflect.EnumNumber
func (TemplateType) String ¶
func (x TemplateType) String() string
func (TemplateType) Type ¶
func (TemplateType) Type() protoreflect.EnumType
type Token ¶
type Token struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` UserIdentifier string `protobuf:"bytes,3,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"` CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*Token) Descriptor
deprecated
func (*Token) GetCreatedAt ¶
func (*Token) GetUpdatedAt ¶
func (*Token) GetUserIdentifier ¶
func (*Token) ProtoMessage ¶
func (*Token) ProtoMessage()
func (*Token) ProtoReflect ¶
func (x *Token) ProtoReflect() protoreflect.Message
type Transformer ¶
type Transformer struct { Define map[string]string `` /* 153-byte string literal not displayed */ Template string `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"` Pipeline []*Action `protobuf:"bytes,3,rep,name=pipeline,proto3" json:"pipeline,omitempty"` TemplateType TemplateType `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Transformer) Descriptor
deprecated
func (*Transformer) Descriptor() ([]byte, []int)
Deprecated: Use Transformer.ProtoReflect.Descriptor instead.
func (*Transformer) GetDefine ¶
func (x *Transformer) GetDefine() map[string]string
func (*Transformer) GetPipeline ¶
func (x *Transformer) GetPipeline() []*Action
func (*Transformer) GetTemplate ¶
func (x *Transformer) GetTemplate() string
func (*Transformer) GetTemplateType ¶
func (x *Transformer) GetTemplateType() TemplateType
func (*Transformer) ProtoMessage ¶
func (*Transformer) ProtoMessage()
func (*Transformer) ProtoReflect ¶
func (x *Transformer) ProtoReflect() protoreflect.Message
func (*Transformer) Reset ¶
func (x *Transformer) Reset()
func (*Transformer) String ¶
func (x *Transformer) String() string
type User ¶
type User struct { Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` CreatedAt int64 `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*User) Descriptor
deprecated
func (*User) GetCreatedAt ¶
func (*User) GetDescription ¶
func (*User) GetIdentifier ¶
func (*User) GetUpdatedAt ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message
type UserRole ¶
type UserRole struct { UserIdentifier string `protobuf:"bytes,1,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"` RoleName string `protobuf:"bytes,2,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"` ResourceId uint64 `protobuf:"varint,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceKind string `protobuf:"bytes,4,opt,name=resource_kind,json=resourceKind,proto3" json:"resource_kind,omitempty"` BuiltIn bool `protobuf:"varint,5,opt,name=built_in,json=builtIn,proto3" json:"built_in,omitempty"` // for custom define role // // string role_id = 6; CreatedAt int64 `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*UserRole) Descriptor
deprecated
func (*UserRole) GetBuiltIn ¶
func (*UserRole) GetCreatedAt ¶
func (*UserRole) GetResourceId ¶
func (*UserRole) GetResourceKind ¶
func (*UserRole) GetRoleName ¶
func (*UserRole) GetUserIdentifier ¶
func (*UserRole) ProtoMessage ¶
func (*UserRole) ProtoMessage()
func (*UserRole) ProtoReflect ¶
func (x *UserRole) ProtoReflect() protoreflect.Message
type VanusResourceName ¶
type VanusResourceName struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*VanusResourceName) Descriptor
deprecated
func (*VanusResourceName) Descriptor() ([]byte, []int)
Deprecated: Use VanusResourceName.ProtoReflect.Descriptor instead.
func (*VanusResourceName) GetValue ¶
func (x *VanusResourceName) GetValue() string
func (*VanusResourceName) ProtoMessage ¶
func (*VanusResourceName) ProtoMessage()
func (*VanusResourceName) ProtoReflect ¶
func (x *VanusResourceName) ProtoReflect() protoreflect.Message
func (*VanusResourceName) Reset ¶
func (x *VanusResourceName) Reset()
func (*VanusResourceName) String ¶
func (x *VanusResourceName) String() string