meta

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2023 License: Apache-2.0 Imports: 5 Imported by: 4

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.

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

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

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

Deprecated: Use ResourceRole.ProtoReflect.Descriptor instead.

func (*ResourceRole) GetBuiltIn added in v0.8.0

func (x *ResourceRole) GetBuiltIn() bool

func (*ResourceRole) GetCreatedAt added in v0.8.0

func (x *ResourceRole) GetCreatedAt() int64

func (*ResourceRole) GetResourceId added in v0.8.0

func (x *ResourceRole) GetResourceId() uint64

func (*ResourceRole) GetResourceKind added in v0.8.0

func (x *ResourceRole) GetResourceKind() string

func (*ResourceRole) GetRoleName added in v0.8.0

func (x *ResourceRole) GetRoleName() string

func (*ResourceRole) GetUserIdentifier added in v0.8.0

func (x *ResourceRole) GetUserIdentifier() string

func (*ResourceRole) ProtoMessage added in v0.8.0

func (*ResourceRole) ProtoMessage()

func (*ResourceRole) ProtoReflect added in v0.8.0

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

func (*ResourceRole) Reset added in v0.8.0

func (x *ResourceRole) Reset()

func (*ResourceRole) String added in v0.8.0

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

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

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

func (TemplateType) Enum added in v0.9.0

func (x TemplateType) Enum() *TemplateType

func (TemplateType) EnumDescriptor deprecated added in v0.9.0

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

Deprecated: Use TemplateType.Descriptor instead.

func (TemplateType) Number added in v0.9.0

func (TemplateType) String added in v0.9.0

func (x TemplateType) String() string

func (TemplateType) Type added in v0.9.0

type Token added in v0.8.0

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

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetCreatedAt added in v0.8.0

func (x *Token) GetCreatedAt() int64

func (*Token) GetId added in v0.8.0

func (x *Token) GetId() uint64

func (*Token) GetToken added in v0.8.0

func (x *Token) GetToken() string

func (*Token) GetUpdatedAt added in v0.8.0

func (x *Token) GetUpdatedAt() int64

func (*Token) GetUserIdentifier added in v0.8.0

func (x *Token) GetUserIdentifier() string

func (*Token) ProtoMessage added in v0.8.0

func (*Token) ProtoMessage()

func (*Token) ProtoReflect added in v0.8.0

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

func (*Token) Reset added in v0.8.0

func (x *Token) Reset()

func (*Token) String added in v0.8.0

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

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

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

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetCreatedAt added in v0.8.0

func (x *User) GetCreatedAt() int64

func (*User) GetDescription added in v0.8.0

func (x *User) GetDescription() string

func (*User) GetIdentifier added in v0.8.0

func (x *User) GetIdentifier() string

func (*User) GetUpdatedAt added in v0.8.0

func (x *User) GetUpdatedAt() int64

func (*User) ProtoMessage added in v0.8.0

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v0.8.0

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

func (*User) Reset added in v0.8.0

func (x *User) Reset()

func (*User) String added in v0.8.0

func (x *User) String() string

type UserRole added in v0.8.0

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

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

Deprecated: Use UserRole.ProtoReflect.Descriptor instead.

func (*UserRole) GetBuiltIn added in v0.8.0

func (x *UserRole) GetBuiltIn() bool

func (*UserRole) GetCreatedAt added in v0.8.0

func (x *UserRole) GetCreatedAt() int64

func (*UserRole) GetResourceId added in v0.8.0

func (x *UserRole) GetResourceId() uint64

func (*UserRole) GetResourceKind added in v0.8.0

func (x *UserRole) GetResourceKind() string

func (*UserRole) GetRoleName added in v0.8.0

func (x *UserRole) GetRoleName() string

func (*UserRole) GetUserIdentifier added in v0.8.0

func (x *UserRole) GetUserIdentifier() string

func (*UserRole) ProtoMessage added in v0.8.0

func (*UserRole) ProtoMessage()

func (*UserRole) ProtoReflect added in v0.8.0

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

func (*UserRole) Reset added in v0.8.0

func (x *UserRole) Reset()

func (*UserRole) String added in v0.8.0

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