meta

package
v0.0.0-...-1334a7b Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
var (
	CompressAlgorithm_name = map[int32]string{
		0: "NONE",
		1: "LZ4",
	}
	CompressAlgorithm_value = map[string]int32{
		"NONE": 0,
		"LZ4":  1,
	}
)

Enum value maps for CompressAlgorithm.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetCommand

func (x *Action) GetCommand() []*structpb.Value

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) ProtoReflect

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

func (*Action) Reset

func (x *Action) Reset()

func (*Action) String

func (x *Action) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetEndpoint

func (x *Block) GetEndpoint() string

func (*Block) GetId

func (x *Block) GetId() uint64

func (*Block) GetVolumeID

func (x *Block) GetVolumeID() uint64

func (*Block) ProtoMessage

func (*Block) ProtoMessage()

func (*Block) ProtoReflect

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

func (*Block) Reset

func (x *Block) Reset()

func (*Block) String

func (x *Block) String() string

type CompressAlgorithm

type CompressAlgorithm int32
const (
	CompressAlgorithm_NONE CompressAlgorithm = 0
	CompressAlgorithm_LZ4  CompressAlgorithm = 1
)

func (CompressAlgorithm) Descriptor

func (CompressAlgorithm) Enum

func (CompressAlgorithm) EnumDescriptor deprecated

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

Deprecated: Use CompressAlgorithm.Descriptor instead.

func (CompressAlgorithm) Number

func (CompressAlgorithm) String

func (x CompressAlgorithm) String() string

func (CompressAlgorithm) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Eventbus.ProtoReflect.Descriptor instead.

func (*Eventbus) GetCreatedAt

func (x *Eventbus) GetCreatedAt() int64

func (*Eventbus) GetDescription

func (x *Eventbus) GetDescription() string

func (*Eventbus) GetId

func (x *Eventbus) GetId() uint64

func (*Eventbus) GetLogNumber

func (x *Eventbus) GetLogNumber() int32

func (*Eventbus) GetLogs

func (x *Eventbus) GetLogs() []*Eventlog

func (*Eventbus) GetName

func (x *Eventbus) GetName() string

func (*Eventbus) GetNamespaceId

func (x *Eventbus) GetNamespaceId() uint64

func (*Eventbus) GetUpdatedAt

func (x *Eventbus) GetUpdatedAt() int64

func (*Eventbus) ProtoMessage

func (*Eventbus) ProtoMessage()

func (*Eventbus) ProtoReflect

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

func (*Eventbus) Reset

func (x *Eventbus) Reset()

func (*Eventbus) String

func (x *Eventbus) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Eventlog.ProtoReflect.Descriptor instead.

func (*Eventlog) GetCurrentSegmentNumbers

func (x *Eventlog) GetCurrentSegmentNumbers() int32

func (*Eventlog) GetEventbusId

func (x *Eventlog) GetEventbusId() uint64

func (*Eventlog) GetEventlogId

func (x *Eventlog) GetEventlogId() uint64

func (*Eventlog) GetServerAddress

func (x *Eventlog) GetServerAddress() []string

func (*Eventlog) ProtoMessage

func (*Eventlog) ProtoMessage()

func (*Eventlog) ProtoReflect

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

func (*Eventlog) Reset

func (x *Eventlog) Reset()

func (*Eventlog) String

func (x *Eventlog) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetAll

func (x *Filter) GetAll() []*Filter

func (*Filter) GetAny

func (x *Filter) GetAny() []*Filter

func (*Filter) GetCel

func (x *Filter) GetCel() string

func (*Filter) GetExact

func (x *Filter) GetExact() map[string]string

func (*Filter) GetNot

func (x *Filter) GetNot() *Filter

func (*Filter) GetPrefix

func (x *Filter) GetPrefix() map[string]string

func (*Filter) GetSql

func (x *Filter) GetSql() string

func (*Filter) GetSuffix

func (x *Filter) GetSuffix() map[string]string

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect

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

func (*Filter) Reset

func (x *Filter) Reset()

func (*Filter) String

func (x *Filter) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetCreatedAt

func (x *Namespace) GetCreatedAt() int64

func (*Namespace) GetDescription

func (x *Namespace) GetDescription() string

func (*Namespace) GetId

func (x *Namespace) GetId() uint64

func (*Namespace) GetName

func (x *Namespace) GetName() string

func (*Namespace) GetUpdatedAt

func (x *Namespace) GetUpdatedAt() int64

func (*Namespace) ProtoMessage

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect

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

func (*Namespace) Reset

func (x *Namespace) Reset()

func (*Namespace) String

func (x *Namespace) String() string

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
const (
	Protocol_HTTP             Protocol = 0
	Protocol_AWS_LAMBDA       Protocol = 1
	Protocol_GCLOUD_FUNCTIONS Protocol = 2
	Protocol_GRPC             Protocol = 3
)

func (Protocol) Descriptor

func (Protocol) Descriptor() protoreflect.EnumDescriptor

func (Protocol) Enum

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated

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

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String

func (x Protocol) String() string

func (Protocol) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Segment.ProtoReflect.Descriptor instead.

func (*Segment) GetCapacity

func (x *Segment) GetCapacity() int64

func (*Segment) GetCompressed

func (x *Segment) GetCompressed() CompressAlgorithm

func (*Segment) GetEndOffsetInLog

func (x *Segment) GetEndOffsetInLog() int64

func (*Segment) GetEventlogId

func (x *Segment) GetEventlogId() uint64

func (*Segment) GetFirstEventBornAtByUnixMs

func (x *Segment) GetFirstEventBornAtByUnixMs() int64

func (*Segment) GetId

func (x *Segment) GetId() uint64

func (*Segment) GetLastEventBornAtByUnixMs

func (x *Segment) GetLastEventBornAtByUnixMs() int64

func (*Segment) GetLeaderBlockId

func (x *Segment) GetLeaderBlockId() uint64

func (*Segment) GetNextSegmentId

func (x *Segment) GetNextSegmentId() uint64

func (*Segment) GetNumberEventStored

func (x *Segment) GetNumberEventStored() int32

func (*Segment) GetPreviousSegmentId

func (x *Segment) GetPreviousSegmentId() uint64

func (*Segment) GetReplicas

func (x *Segment) GetReplicas() map[uint64]*Block

func (*Segment) GetSize

func (x *Segment) GetSize() int64

func (*Segment) GetStartOffsetInLog

func (x *Segment) GetStartOffsetInLog() int64

func (*Segment) GetState

func (x *Segment) GetState() string

func (*Segment) ProtoMessage

func (*Segment) ProtoMessage()

func (*Segment) ProtoReflect

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

func (*Segment) Reset

func (x *Segment) Reset()

func (*Segment) String

func (x *Segment) String() string

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

func (SinkCredential_CredentialType) EnumDescriptor deprecated

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

Deprecated: Use SinkCredential_CredentialType.Descriptor instead.

func (SinkCredential_CredentialType) Number

func (SinkCredential_CredentialType) String

func (SinkCredential_CredentialType) Type

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

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 (*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) Enum

func (SubscriptionConfig_OffsetType) EnumDescriptor deprecated

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

Deprecated: Use SubscriptionConfig_OffsetType.Descriptor instead.

func (SubscriptionConfig_OffsetType) Number

func (SubscriptionConfig_OffsetType) String

func (SubscriptionConfig_OffsetType) Type

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

func (x TemplateType) Enum() *TemplateType

func (TemplateType) EnumDescriptor deprecated

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

Deprecated: Use TemplateType.Descriptor instead.

func (TemplateType) Number

func (TemplateType) String

func (x TemplateType) String() string

func (TemplateType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetCreatedAt

func (x *Token) GetCreatedAt() int64

func (*Token) GetId

func (x *Token) GetId() uint64

func (*Token) GetToken

func (x *Token) GetToken() string

func (*Token) GetUpdatedAt

func (x *Token) GetUpdatedAt() int64

func (*Token) GetUserIdentifier

func (x *Token) GetUserIdentifier() string

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) ProtoReflect

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

func (*Token) Reset

func (x *Token) Reset()

func (*Token) String

func (x *Token) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetCreatedAt

func (x *User) GetCreatedAt() int64

func (*User) GetDescription

func (x *User) GetDescription() string

func (*User) GetIdentifier

func (x *User) GetIdentifier() string

func (*User) GetUpdatedAt

func (x *User) GetUpdatedAt() int64

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UserRole.ProtoReflect.Descriptor instead.

func (*UserRole) GetBuiltIn

func (x *UserRole) GetBuiltIn() bool

func (*UserRole) GetCreatedAt

func (x *UserRole) GetCreatedAt() int64

func (*UserRole) GetResourceId

func (x *UserRole) GetResourceId() uint64

func (*UserRole) GetResourceKind

func (x *UserRole) GetResourceKind() string

func (*UserRole) GetRoleName

func (x *UserRole) GetRoleName() string

func (*UserRole) GetUserIdentifier

func (x *UserRole) GetUserIdentifier() string

func (*UserRole) ProtoMessage

func (*UserRole) ProtoMessage()

func (*UserRole) ProtoReflect

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

func (*UserRole) Reset

func (x *UserRole) Reset()

func (*UserRole) String

func (x *UserRole) String() string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL