meta

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
}

type Action struct {
	Command []*structpb.Value `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

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
}

type CompressAlgorithm int32

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
}

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
}

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
}

type GCloudCredential struct {
	CredentialsJson string `protobuf:"bytes,1,opt,name=credentials_json,json=credentialsJson,proto3" json:"credentials_json,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

type Protocol int32

type ProtocolSetting struct {
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

type SinkCredential_Aws struct {
	Aws *AKSKCredential `protobuf:"bytes,3,opt,name=aws,proto3,oneof"`
}

type SinkCredential_CredentialType int32

type SinkCredential_Gcloud struct {
	Gcloud *GCloudCredential `protobuf:"bytes,4,opt,name=gcloud,proto3,oneof"`
}

type SinkCredential_Plain struct {
	Plain *PlainCredential `protobuf:"bytes,2,opt,name=plain,proto3,oneof"`
}

type StorageTier int32

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
}

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
}

type SubscriptionConfig_OffsetType int32

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
}

type TemplateType int32

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
}

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
}

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
}

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
}

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