Ydb_PersQueue_V1

package
v2.10.8 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Codec_name = map[int32]string{
	0: "CODEC_UNSPECIFIED",
	1: "CODEC_RAW",
	2: "CODEC_GZIP",
	3: "CODEC_LZOP",
	4: "CODEC_ZSTD",
}
View Source 
var Codec_value = map[string]int32{
	"CODEC_UNSPECIFIED": 0,
	"CODEC_RAW":         1,
	"CODEC_GZIP":        2,
	"CODEC_LZOP":        3,
	"CODEC_ZSTD":        4,
}
View Source 
var MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status_name = map[int32]string{
	0: "STATUS_UNSPECIFIED",
	1: "CREATING",
	2: "DESTROYING",
	3: "READING",
	4: "STOPPED",
}
View Source 
var MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status_value = map[string]int32{
	"STATUS_UNSPECIFIED": 0,
	"CREATING":           1,
	"DESTROYING":         2,
	"READING":            3,
	"STOPPED":            4,
}
View Source 
var StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status_name = map[int32]string{
	0: "STATUS_UNSPECIFIED",
	1: "CREATING",
	2: "DESTROYING",
	3: "READING",
	4: "STOPPED",
}
View Source 
var StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status_value = map[string]int32{
	"STATUS_UNSPECIFIED": 0,
	"CREATING":           1,
	"DESTROYING":         2,
	"READING":            3,
	"STOPPED":            4,
}
View Source 
var TopicSettings_Format_name = map[int32]string{
	0: "FORMAT_UNSPECIFIED",
	1: "FORMAT_BASE",
}
View Source 
var TopicSettings_Format_value = map[string]int32{
	"FORMAT_UNSPECIFIED": 0,
	"FORMAT_BASE":        1,
}

Functions

This section is empty.

Types

type AddReadRuleRequest 

type AddReadRuleRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// read rules to add
	ReadRule             *TopicSettings_ReadRule `protobuf:"bytes,3,opt,name=read_rule,json=readRule,proto3" json:"read_rule,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

* Add read rules for existing topic request.

func (*AddReadRuleRequest) Descriptor 

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

func (*AddReadRuleRequest) GetOperationParams 

func (m *AddReadRuleRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AddReadRuleRequest) GetPath 

func (m *AddReadRuleRequest) GetPath() string

func (*AddReadRuleRequest) GetReadRule 

func (m *AddReadRuleRequest) GetReadRule() *TopicSettings_ReadRule

func (*AddReadRuleRequest) ProtoMessage 

func (*AddReadRuleRequest) ProtoMessage()

func (*AddReadRuleRequest) Reset 

func (m *AddReadRuleRequest) Reset()

func (*AddReadRuleRequest) SetOperationParams 

func (m *AddReadRuleRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*AddReadRuleRequest) String 

func (m *AddReadRuleRequest) String() string

func (*AddReadRuleRequest) XXX_DiscardUnknown 

func (m *AddReadRuleRequest) XXX_DiscardUnknown()

func (*AddReadRuleRequest) XXX_Marshal 

func (m *AddReadRuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddReadRuleRequest) XXX_Merge 

func (m *AddReadRuleRequest) XXX_Merge(src proto.Message)

func (*AddReadRuleRequest) XXX_Size 

func (m *AddReadRuleRequest) XXX_Size() int

func (*AddReadRuleRequest) XXX_Unmarshal 

func (m *AddReadRuleRequest) XXX_Unmarshal(b []byte) error

type AddReadRuleResponse 

type AddReadRuleResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* Add read rules for existing topic response.

func (*AddReadRuleResponse) Descriptor 

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

func (*AddReadRuleResponse) GetOperation 

func (m *AddReadRuleResponse) GetOperation() *Ydb_Operations.Operation

func (*AddReadRuleResponse) ProtoMessage 

func (*AddReadRuleResponse) ProtoMessage()

func (*AddReadRuleResponse) Reset 

func (m *AddReadRuleResponse) Reset()

func (*AddReadRuleResponse) String 

func (m *AddReadRuleResponse) String() string

func (*AddReadRuleResponse) XXX_DiscardUnknown 

func (m *AddReadRuleResponse) XXX_DiscardUnknown()

func (*AddReadRuleResponse) XXX_Marshal 

func (m *AddReadRuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddReadRuleResponse) XXX_Merge 

func (m *AddReadRuleResponse) XXX_Merge(src proto.Message)

func (*AddReadRuleResponse) XXX_Size 

func (m *AddReadRuleResponse) XXX_Size() int

func (*AddReadRuleResponse) XXX_Unmarshal 

func (m *AddReadRuleResponse) XXX_Unmarshal(b []byte) error

type AddReadRuleResult 

type AddReadRuleResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Add read rules result message that will be inside AddReadRuleReponse.operation.

func (*AddReadRuleResult) Descriptor 

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

func (*AddReadRuleResult) ProtoMessage 

func (*AddReadRuleResult) ProtoMessage()

func (*AddReadRuleResult) Reset 

func (m *AddReadRuleResult) Reset()

func (*AddReadRuleResult) String 

func (m *AddReadRuleResult) String() string

func (*AddReadRuleResult) XXX_DiscardUnknown 

func (m *AddReadRuleResult) XXX_DiscardUnknown()

func (*AddReadRuleResult) XXX_Marshal 

func (m *AddReadRuleResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddReadRuleResult) XXX_Merge 

func (m *AddReadRuleResult) XXX_Merge(src proto.Message)

func (*AddReadRuleResult) XXX_Size 

func (m *AddReadRuleResult) XXX_Size() int

func (*AddReadRuleResult) XXX_Unmarshal 

func (m *AddReadRuleResult) XXX_Unmarshal(b []byte) error

type AlterTopicRequest 

type AlterTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// New topic settings to be set. All options inside should be set despite same value.
	Settings             *TopicSettings `protobuf:"bytes,4,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AlterTopicRequest) Descriptor 

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

func (*AlterTopicRequest) GetOperationParams 

func (m *AlterTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AlterTopicRequest) GetPath 

func (m *AlterTopicRequest) GetPath() string

func (*AlterTopicRequest) GetSettings 

func (m *AlterTopicRequest) GetSettings() *TopicSettings

func (*AlterTopicRequest) ProtoMessage 

func (*AlterTopicRequest) ProtoMessage()

func (*AlterTopicRequest) Reset 

func (m *AlterTopicRequest) Reset()

func (*AlterTopicRequest) SetOperationParams 

func (m *AlterTopicRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*AlterTopicRequest) String 

func (m *AlterTopicRequest) String() string

func (*AlterTopicRequest) XXX_DiscardUnknown 

func (m *AlterTopicRequest) XXX_DiscardUnknown()

func (*AlterTopicRequest) XXX_Marshal 

func (m *AlterTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTopicRequest) XXX_Merge 

func (m *AlterTopicRequest) XXX_Merge(src proto.Message)

func (*AlterTopicRequest) XXX_Size 

func (m *AlterTopicRequest) XXX_Size() int

func (*AlterTopicRequest) XXX_Unmarshal 

func (m *AlterTopicRequest) XXX_Unmarshal(b []byte) error

type AlterTopicResponse 

type AlterTopicResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AlterTopicResponse) Descriptor 

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

func (*AlterTopicResponse) GetOperation 

func (m *AlterTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*AlterTopicResponse) ProtoMessage 

func (*AlterTopicResponse) ProtoMessage()

func (*AlterTopicResponse) Reset 

func (m *AlterTopicResponse) Reset()

func (*AlterTopicResponse) String 

func (m *AlterTopicResponse) String() string

func (*AlterTopicResponse) XXX_DiscardUnknown 

func (m *AlterTopicResponse) XXX_DiscardUnknown()

func (*AlterTopicResponse) XXX_Marshal 

func (m *AlterTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTopicResponse) XXX_Merge 

func (m *AlterTopicResponse) XXX_Merge(src proto.Message)

func (*AlterTopicResponse) XXX_Size 

func (m *AlterTopicResponse) XXX_Size() int

func (*AlterTopicResponse) XXX_Unmarshal 

func (m *AlterTopicResponse) XXX_Unmarshal(b []byte) error

type AlterTopicResult 

type AlterTopicResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Update topic result message that will be inside UpdateTopicResponse.operation.

func (*AlterTopicResult) Descriptor 

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

func (*AlterTopicResult) ProtoMessage 

func (*AlterTopicResult) ProtoMessage()

func (*AlterTopicResult) Reset 

func (m *AlterTopicResult) Reset()

func (*AlterTopicResult) String 

func (m *AlterTopicResult) String() string

func (*AlterTopicResult) XXX_DiscardUnknown 

func (m *AlterTopicResult) XXX_DiscardUnknown()

func (*AlterTopicResult) XXX_Marshal 

func (m *AlterTopicResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTopicResult) XXX_Merge 

func (m *AlterTopicResult) XXX_Merge(src proto.Message)

func (*AlterTopicResult) XXX_Size 

func (m *AlterTopicResult) XXX_Size() int

func (*AlterTopicResult) XXX_Unmarshal 

func (m *AlterTopicResult) XXX_Unmarshal(b []byte) error

type Codec 

type Codec int32
const (
	Codec_CODEC_UNSPECIFIED Codec = 0
	Codec_CODEC_RAW         Codec = 1
	Codec_CODEC_GZIP        Codec = 2
	Codec_CODEC_LZOP        Codec = 3
	Codec_CODEC_ZSTD        Codec = 4
)

func (Codec) EnumDescriptor 

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

func (Codec) String 

func (x Codec) String() string

type CommitCookie 

type CommitCookie struct {
	// Assign identitifier of assigned partition from which read was done.
	AssignId uint64 `protobuf:"varint,1,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	// Incremental identifier of concrete partition read batch.
	PartitionCookie      uint64   `protobuf:"varint,2,opt,name=partition_cookie,json=partitionCookie,proto3" json:"partition_cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Message that is used for addressing read for commiting.

func (*CommitCookie) Descriptor 

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

func (*CommitCookie) GetAssignId 

func (m *CommitCookie) GetAssignId() uint64

func (*CommitCookie) GetPartitionCookie 

func (m *CommitCookie) GetPartitionCookie() uint64

func (*CommitCookie) ProtoMessage 

func (*CommitCookie) ProtoMessage()

func (*CommitCookie) Reset 

func (m *CommitCookie) Reset()

func (*CommitCookie) String 

func (m *CommitCookie) String() string

func (*CommitCookie) XXX_DiscardUnknown 

func (m *CommitCookie) XXX_DiscardUnknown()

func (*CommitCookie) XXX_Marshal 

func (m *CommitCookie) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitCookie) XXX_Merge 

func (m *CommitCookie) XXX_Merge(src proto.Message)

func (*CommitCookie) XXX_Size 

func (m *CommitCookie) XXX_Size() int

func (*CommitCookie) XXX_Unmarshal 

func (m *CommitCookie) XXX_Unmarshal(b []byte) error

type CommitOffsetRange 

type CommitOffsetRange struct {
	AssignId             uint64   `protobuf:"varint,1,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	StartOffset          uint64   `protobuf:"varint,2,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset            uint64   `protobuf:"varint,3,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitOffsetRange) Descriptor 

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

func (*CommitOffsetRange) GetAssignId 

func (m *CommitOffsetRange) GetAssignId() uint64

func (*CommitOffsetRange) GetEndOffset 

func (m *CommitOffsetRange) GetEndOffset() uint64

func (*CommitOffsetRange) GetStartOffset 

func (m *CommitOffsetRange) GetStartOffset() uint64

func (*CommitOffsetRange) ProtoMessage 

func (*CommitOffsetRange) ProtoMessage()

func (*CommitOffsetRange) Reset 

func (m *CommitOffsetRange) Reset()

func (*CommitOffsetRange) String 

func (m *CommitOffsetRange) String() string

func (*CommitOffsetRange) XXX_DiscardUnknown 

func (m *CommitOffsetRange) XXX_DiscardUnknown()

func (*CommitOffsetRange) XXX_Marshal 

func (m *CommitOffsetRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitOffsetRange) XXX_Merge 

func (m *CommitOffsetRange) XXX_Merge(src proto.Message)

func (*CommitOffsetRange) XXX_Size 

func (m *CommitOffsetRange) XXX_Size() int

func (*CommitOffsetRange) XXX_Unmarshal 

func (m *CommitOffsetRange) XXX_Unmarshal(b []byte) error

type CreateTopicRequest 

type CreateTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Topic settings.
	Settings             *TopicSettings `protobuf:"bytes,4,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateTopicRequest) Descriptor 

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

func (*CreateTopicRequest) GetOperationParams 

func (m *CreateTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateTopicRequest) GetPath 

func (m *CreateTopicRequest) GetPath() string

func (*CreateTopicRequest) GetSettings 

func (m *CreateTopicRequest) GetSettings() *TopicSettings

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) Reset 

func (m *CreateTopicRequest) Reset()

func (*CreateTopicRequest) SetOperationParams 

func (m *CreateTopicRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CreateTopicRequest) String 

func (m *CreateTopicRequest) String() string

func (*CreateTopicRequest) XXX_DiscardUnknown 

func (m *CreateTopicRequest) XXX_DiscardUnknown()

func (*CreateTopicRequest) XXX_Marshal 

func (m *CreateTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTopicRequest) XXX_Merge 

func (m *CreateTopicRequest) XXX_Merge(src proto.Message)

func (*CreateTopicRequest) XXX_Size 

func (m *CreateTopicRequest) XXX_Size() int

func (*CreateTopicRequest) XXX_Unmarshal 

func (m *CreateTopicRequest) XXX_Unmarshal(b []byte) error

type CreateTopicResponse 

type CreateTopicResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CreateTopicResponse) Descriptor 

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

func (*CreateTopicResponse) GetOperation 

func (m *CreateTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateTopicResponse) ProtoMessage 

func (*CreateTopicResponse) ProtoMessage()

func (*CreateTopicResponse) Reset 

func (m *CreateTopicResponse) Reset()

func (*CreateTopicResponse) String 

func (m *CreateTopicResponse) String() string

func (*CreateTopicResponse) XXX_DiscardUnknown 

func (m *CreateTopicResponse) XXX_DiscardUnknown()

func (*CreateTopicResponse) XXX_Marshal 

func (m *CreateTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTopicResponse) XXX_Merge 

func (m *CreateTopicResponse) XXX_Merge(src proto.Message)

func (*CreateTopicResponse) XXX_Size 

func (m *CreateTopicResponse) XXX_Size() int

func (*CreateTopicResponse) XXX_Unmarshal 

func (m *CreateTopicResponse) XXX_Unmarshal(b []byte) error

type CreateTopicResult 

type CreateTopicResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTopicResult) Descriptor 

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

func (*CreateTopicResult) ProtoMessage 

func (*CreateTopicResult) ProtoMessage()

func (*CreateTopicResult) Reset 

func (m *CreateTopicResult) Reset()

func (*CreateTopicResult) String 

func (m *CreateTopicResult) String() string

func (*CreateTopicResult) XXX_DiscardUnknown 

func (m *CreateTopicResult) XXX_DiscardUnknown()

func (*CreateTopicResult) XXX_Marshal 

func (m *CreateTopicResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTopicResult) XXX_Merge 

func (m *CreateTopicResult) XXX_Merge(src proto.Message)

func (*CreateTopicResult) XXX_Size 

func (m *CreateTopicResult) XXX_Size() int

func (*CreateTopicResult) XXX_Unmarshal 

func (m *CreateTopicResult) XXX_Unmarshal(b []byte) error

type Credentials 

type Credentials struct {
	// Types that are valid to be assigned to Credentials:
	//	*Credentials_OauthToken
	//	*Credentials_JwtParams
	//	*Credentials_Iam_
	Credentials          isCredentials_Credentials `protobuf_oneof:"credentials"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Credentials) Descriptor 

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

func (*Credentials) GetCredentials 

func (m *Credentials) GetCredentials() isCredentials_Credentials

func (*Credentials) GetIam 

func (m *Credentials) GetIam() *Credentials_Iam

func (*Credentials) GetJwtParams 

func (m *Credentials) GetJwtParams() string

func (*Credentials) GetOauthToken 

func (m *Credentials) GetOauthToken() string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) String 

func (m *Credentials) String() string

func (*Credentials) XXX_DiscardUnknown 

func (m *Credentials) XXX_DiscardUnknown()

func (*Credentials) XXX_Marshal 

func (m *Credentials) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Credentials) XXX_Merge 

func (m *Credentials) XXX_Merge(src proto.Message)

func (*Credentials) XXX_OneofWrappers 

func (*Credentials) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Credentials) XXX_Size 

func (m *Credentials) XXX_Size() int

func (*Credentials) XXX_Unmarshal 

func (m *Credentials) XXX_Unmarshal(b []byte) error

type Credentials_Iam 

type Credentials_Iam struct {
	Endpoint             string   `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	ServiceAccountKey    string   `protobuf:"bytes,2,opt,name=service_account_key,json=serviceAccountKey,proto3" json:"service_account_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Credentials_Iam) Descriptor 

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

func (*Credentials_Iam) GetEndpoint 

func (m *Credentials_Iam) GetEndpoint() string

func (*Credentials_Iam) GetServiceAccountKey 

func (m *Credentials_Iam) GetServiceAccountKey() string

func (*Credentials_Iam) ProtoMessage 

func (*Credentials_Iam) ProtoMessage()

func (*Credentials_Iam) Reset 

func (m *Credentials_Iam) Reset()

func (*Credentials_Iam) String 

func (m *Credentials_Iam) String() string

func (*Credentials_Iam) XXX_DiscardUnknown 

func (m *Credentials_Iam) XXX_DiscardUnknown()

func (*Credentials_Iam) XXX_Marshal 

func (m *Credentials_Iam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Credentials_Iam) XXX_Merge 

func (m *Credentials_Iam) XXX_Merge(src proto.Message)

func (*Credentials_Iam) XXX_Size 

func (m *Credentials_Iam) XXX_Size() int

func (*Credentials_Iam) XXX_Unmarshal 

func (m *Credentials_Iam) XXX_Unmarshal(b []byte) error

type Credentials_Iam_ 

type Credentials_Iam_ struct {
	Iam *Credentials_Iam `protobuf:"bytes,3,opt,name=iam,proto3,oneof"`
}

type Credentials_JwtParams 

type Credentials_JwtParams struct {
	JwtParams string `protobuf:"bytes,2,opt,name=jwt_params,json=jwtParams,proto3,oneof"`
}

type Credentials_OauthToken 

type Credentials_OauthToken struct {
	OauthToken string `protobuf:"bytes,1,opt,name=oauth_token,json=oauthToken,proto3,oneof"`
}

type DescribeTopicRequest 

type DescribeTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeTopicRequest) Descriptor 

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

func (*DescribeTopicRequest) GetOperationParams 

func (m *DescribeTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeTopicRequest) GetPath 

func (m *DescribeTopicRequest) GetPath() string

func (*DescribeTopicRequest) ProtoMessage 

func (*DescribeTopicRequest) ProtoMessage()

func (*DescribeTopicRequest) Reset 

func (m *DescribeTopicRequest) Reset()

func (*DescribeTopicRequest) SetOperationParams 

func (m *DescribeTopicRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DescribeTopicRequest) String 

func (m *DescribeTopicRequest) String() string

func (*DescribeTopicRequest) XXX_DiscardUnknown 

func (m *DescribeTopicRequest) XXX_DiscardUnknown()

func (*DescribeTopicRequest) XXX_Marshal 

func (m *DescribeTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTopicRequest) XXX_Merge 

func (m *DescribeTopicRequest) XXX_Merge(src proto.Message)

func (*DescribeTopicRequest) XXX_Size 

func (m *DescribeTopicRequest) XXX_Size() int

func (*DescribeTopicRequest) XXX_Unmarshal 

func (m *DescribeTopicRequest) XXX_Unmarshal(b []byte) error

type DescribeTopicResponse 

type DescribeTopicResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DescribeTopicResponse) Descriptor 

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

func (*DescribeTopicResponse) GetOperation 

func (m *DescribeTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeTopicResponse) ProtoMessage 

func (*DescribeTopicResponse) ProtoMessage()

func (*DescribeTopicResponse) Reset 

func (m *DescribeTopicResponse) Reset()

func (*DescribeTopicResponse) String 

func (m *DescribeTopicResponse) String() string

func (*DescribeTopicResponse) XXX_DiscardUnknown 

func (m *DescribeTopicResponse) XXX_DiscardUnknown()

func (*DescribeTopicResponse) XXX_Marshal 

func (m *DescribeTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTopicResponse) XXX_Merge 

func (m *DescribeTopicResponse) XXX_Merge(src proto.Message)

func (*DescribeTopicResponse) XXX_Size 

func (m *DescribeTopicResponse) XXX_Size() int

func (*DescribeTopicResponse) XXX_Unmarshal 

func (m *DescribeTopicResponse) XXX_Unmarshal(b []byte) error

type DescribeTopicResult 

type DescribeTopicResult struct {
	// Topic path.
	Self *Ydb_Scheme.Entry `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	// Settings of topic.
	Settings             *TopicSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DescribeTopicResult) Descriptor 

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

func (*DescribeTopicResult) GetSelf 

func (m *DescribeTopicResult) GetSelf() *Ydb_Scheme.Entry

func (*DescribeTopicResult) GetSettings 

func (m *DescribeTopicResult) GetSettings() *TopicSettings

func (*DescribeTopicResult) ProtoMessage 

func (*DescribeTopicResult) ProtoMessage()

func (*DescribeTopicResult) Reset 

func (m *DescribeTopicResult) Reset()

func (*DescribeTopicResult) String 

func (m *DescribeTopicResult) String() string

func (*DescribeTopicResult) XXX_DiscardUnknown 

func (m *DescribeTopicResult) XXX_DiscardUnknown()

func (*DescribeTopicResult) XXX_Marshal 

func (m *DescribeTopicResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTopicResult) XXX_Merge 

func (m *DescribeTopicResult) XXX_Merge(src proto.Message)

func (*DescribeTopicResult) XXX_Size 

func (m *DescribeTopicResult) XXX_Size() int

func (*DescribeTopicResult) XXX_Unmarshal 

func (m *DescribeTopicResult) XXX_Unmarshal(b []byte) error

type DropTopicRequest 

type DropTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropTopicRequest) Descriptor 

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

func (*DropTopicRequest) GetOperationParams 

func (m *DropTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DropTopicRequest) GetPath 

func (m *DropTopicRequest) GetPath() string

func (*DropTopicRequest) ProtoMessage 

func (*DropTopicRequest) ProtoMessage()

func (*DropTopicRequest) Reset 

func (m *DropTopicRequest) Reset()

func (*DropTopicRequest) SetOperationParams 

func (m *DropTopicRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DropTopicRequest) String 

func (m *DropTopicRequest) String() string

func (*DropTopicRequest) XXX_DiscardUnknown 

func (m *DropTopicRequest) XXX_DiscardUnknown()

func (*DropTopicRequest) XXX_Marshal 

func (m *DropTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTopicRequest) XXX_Merge 

func (m *DropTopicRequest) XXX_Merge(src proto.Message)

func (*DropTopicRequest) XXX_Size 

func (m *DropTopicRequest) XXX_Size() int

func (*DropTopicRequest) XXX_Unmarshal 

func (m *DropTopicRequest) XXX_Unmarshal(b []byte) error

type DropTopicResponse 

type DropTopicResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DropTopicResponse) Descriptor 

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

func (*DropTopicResponse) GetOperation 

func (m *DropTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*DropTopicResponse) ProtoMessage 

func (*DropTopicResponse) ProtoMessage()

func (*DropTopicResponse) Reset 

func (m *DropTopicResponse) Reset()

func (*DropTopicResponse) String 

func (m *DropTopicResponse) String() string

func (*DropTopicResponse) XXX_DiscardUnknown 

func (m *DropTopicResponse) XXX_DiscardUnknown()

func (*DropTopicResponse) XXX_Marshal 

func (m *DropTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTopicResponse) XXX_Merge 

func (m *DropTopicResponse) XXX_Merge(src proto.Message)

func (*DropTopicResponse) XXX_Size 

func (m *DropTopicResponse) XXX_Size() int

func (*DropTopicResponse) XXX_Unmarshal 

func (m *DropTopicResponse) XXX_Unmarshal(b []byte) error

type DropTopicResult 

type DropTopicResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropTopicResult) Descriptor 

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

func (*DropTopicResult) ProtoMessage 

func (*DropTopicResult) ProtoMessage()

func (*DropTopicResult) Reset 

func (m *DropTopicResult) Reset()

func (*DropTopicResult) String 

func (m *DropTopicResult) String() string

func (*DropTopicResult) XXX_DiscardUnknown 

func (m *DropTopicResult) XXX_DiscardUnknown()

func (*DropTopicResult) XXX_Marshal 

func (m *DropTopicResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTopicResult) XXX_Merge 

func (m *DropTopicResult) XXX_Merge(src proto.Message)

func (*DropTopicResult) XXX_Size 

func (m *DropTopicResult) XXX_Size() int

func (*DropTopicResult) XXX_Unmarshal 

func (m *DropTopicResult) XXX_Unmarshal(b []byte) error

type KeyValue 

type KeyValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValue) XXX_Merge 

func (m *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage 

type MigrationStreamingReadClientMessage struct {
	// Types that are valid to be assigned to Request:
	//	*MigrationStreamingReadClientMessage_InitRequest_
	//	*MigrationStreamingReadClientMessage_Read_
	//	*MigrationStreamingReadClientMessage_StartRead_
	//	*MigrationStreamingReadClientMessage_Commit_
	//	*MigrationStreamingReadClientMessage_Released_
	//	*MigrationStreamingReadClientMessage_Status_
	Request isMigrationStreamingReadClientMessage_Request `protobuf_oneof:"request"`
	// User credentials if update is needed or empty string.
	Token                []byte   `protobuf:"bytes,20,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MigrationStreamingReadClientMessage) Descriptor 

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

func (*MigrationStreamingReadClientMessage) GetCommit 

func (m *MigrationStreamingReadClientMessage) GetCommit() *MigrationStreamingReadClientMessage_Commit

func (*MigrationStreamingReadClientMessage) GetInitRequest 

func (m *MigrationStreamingReadClientMessage) GetInitRequest() *MigrationStreamingReadClientMessage_InitRequest

func (*MigrationStreamingReadClientMessage) GetRead 

func (m *MigrationStreamingReadClientMessage) GetRead() *MigrationStreamingReadClientMessage_Read

func (*MigrationStreamingReadClientMessage) GetReleased 

func (m *MigrationStreamingReadClientMessage) GetReleased() *MigrationStreamingReadClientMessage_Released

func (*MigrationStreamingReadClientMessage) GetRequest 

func (m *MigrationStreamingReadClientMessage) GetRequest() isMigrationStreamingReadClientMessage_Request

func (*MigrationStreamingReadClientMessage) GetStartRead 

func (m *MigrationStreamingReadClientMessage) GetStartRead() *MigrationStreamingReadClientMessage_StartRead

func (*MigrationStreamingReadClientMessage) GetStatus 

func (m *MigrationStreamingReadClientMessage) GetStatus() *MigrationStreamingReadClientMessage_Status

func (*MigrationStreamingReadClientMessage) GetToken 

func (m *MigrationStreamingReadClientMessage) GetToken() []byte

func (*MigrationStreamingReadClientMessage) ProtoMessage 

func (*MigrationStreamingReadClientMessage) ProtoMessage()

func (*MigrationStreamingReadClientMessage) Reset 

func (m *MigrationStreamingReadClientMessage) Reset()

func (*MigrationStreamingReadClientMessage) String 

func (m *MigrationStreamingReadClientMessage) String() string

func (*MigrationStreamingReadClientMessage) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage) XXX_Merge 

func (m *MigrationStreamingReadClientMessage) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage) XXX_OneofWrappers 

func (*MigrationStreamingReadClientMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MigrationStreamingReadClientMessage) XXX_Size 

func (m *MigrationStreamingReadClientMessage) XXX_Size() int

func (*MigrationStreamingReadClientMessage) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_Commit 

type MigrationStreamingReadClientMessage_Commit struct {
	// Partition read cookies that indicates processed data.
	Cookies              []*CommitCookie      `protobuf:"bytes,1,rep,name=cookies,proto3" json:"cookies,omitempty"`
	OffsetRanges         []*CommitOffsetRange `protobuf:"bytes,2,rep,name=offset_ranges,json=offsetRanges,proto3" json:"offset_ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Signal for server that client processed some read data.

func (*MigrationStreamingReadClientMessage_Commit) Descriptor 

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

func (*MigrationStreamingReadClientMessage_Commit) GetCookies 

func (m *MigrationStreamingReadClientMessage_Commit) GetCookies() []*CommitCookie

func (*MigrationStreamingReadClientMessage_Commit) GetOffsetRanges 

func (m *MigrationStreamingReadClientMessage_Commit) GetOffsetRanges() []*CommitOffsetRange

func (*MigrationStreamingReadClientMessage_Commit) ProtoMessage 

func (*MigrationStreamingReadClientMessage_Commit) ProtoMessage()

func (*MigrationStreamingReadClientMessage_Commit) Reset 

func (m *MigrationStreamingReadClientMessage_Commit) Reset()

func (*MigrationStreamingReadClientMessage_Commit) String 

func (m *MigrationStreamingReadClientMessage_Commit) String() string

func (*MigrationStreamingReadClientMessage_Commit) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_Commit) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_Commit) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_Commit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_Commit) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_Commit) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_Commit) XXX_Size 

func (m *MigrationStreamingReadClientMessage_Commit) XXX_Size() int

func (*MigrationStreamingReadClientMessage_Commit) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_Commit) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_Commit_ 

type MigrationStreamingReadClientMessage_Commit_ struct {
	Commit *MigrationStreamingReadClientMessage_Commit `protobuf:"bytes,4,opt,name=commit,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_InitRequest 

type MigrationStreamingReadClientMessage_InitRequest struct {
	// Message that describes topic to read.
	// Topics that will be read by this session.
	TopicsReadSettings []*MigrationStreamingReadClientMessage_TopicReadSettings `protobuf:"bytes,1,rep,name=topics_read_settings,json=topicsReadSettings,proto3" json:"topics_read_settings,omitempty"`
	// Flag that indicates reading only of original topics in cluster or all including mirrored.
	ReadOnlyOriginal bool `protobuf:"varint,2,opt,name=read_only_original,json=readOnlyOriginal,proto3" json:"read_only_original,omitempty"`
	// Path of consumer that is used for reading by this session.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Skip all messages that has write timestamp smaller than now - max_time_lag_ms.
	MaxLagDurationMs int64 `protobuf:"varint,4,opt,name=max_lag_duration_ms,json=maxLagDurationMs,proto3" json:"max_lag_duration_ms,omitempty"`
	// Read data only after this timestamp from all topics.
	StartFromWrittenAtMs int64 `` /* 128-byte string literal not displayed */
	// Maximum block format version supported by the client. Server will asses this parameter and return actual data blocks version in
	// StreamingReadServerMessage.InitResponse.block_format_version_by_topic (and StreamingReadServerMessage.AddTopicResponse.block_format_version)
	// or error if client will not be able to read data.
	MaxSupportedBlockFormatVersion int64 `` /* 158-byte string literal not displayed */
	// Maximal size of client cache for message_group_id, ip and meta, per partition.
	// There is separate caches for each partition partition streams.
	// There is separate caches for message group identifiers, ip and meta inside one partition partition stream.
	MaxMetaCacheSize int64 `protobuf:"varint,10,opt,name=max_meta_cache_size,json=maxMetaCacheSize,proto3" json:"max_meta_cache_size,omitempty"`
	// Session identifier for retries. Must be the same as session_id from Inited server response. If this is first connect, not retry - do not use this field.
	SessionId string `protobuf:"bytes,100,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// 0 for first init message and incremental value for connect retries.
	ConnectionAttempt int64 `protobuf:"varint,101,opt,name=connection_attempt,json=connectionAttempt,proto3" json:"connection_attempt,omitempty"`
	// Formed state for retries. If not retry - do not use this field.
	State         *MigrationStreamingReadClientMessage_InitRequest_State `protobuf:"bytes,102,opt,name=state,proto3" json:"state,omitempty"`
	IdleTimeoutMs int64                                                  `protobuf:"varint,200,opt,name=idle_timeout_ms,json=idleTimeoutMs,proto3" json:"idle_timeout_ms,omitempty"`
	////////////////////////////////////////////////////////////////////////////////////////////////////////////
	// TODO: remove after refactoring
	// Single read request params.
	ReadParams           *ReadParams `protobuf:"bytes,42,opt,name=read_params,json=readParams,proto3" json:"read_params,omitempty"`
	RangesMode           bool        `protobuf:"varint,442,opt,name=ranges_mode,json=rangesMode,proto3" json:"ranges_mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Handshake request.

func (*MigrationStreamingReadClientMessage_InitRequest) Descriptor 

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

func (*MigrationStreamingReadClientMessage_InitRequest) GetConnectionAttempt 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetConnectionAttempt() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetConsumer 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetConsumer() string

func (*MigrationStreamingReadClientMessage_InitRequest) GetIdleTimeoutMs 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetIdleTimeoutMs() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetMaxLagDurationMs 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetMaxLagDurationMs() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetMaxMetaCacheSize 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetMaxMetaCacheSize() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetMaxSupportedBlockFormatVersion 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetMaxSupportedBlockFormatVersion() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetRangesMode 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetRangesMode() bool

func (*MigrationStreamingReadClientMessage_InitRequest) GetReadOnlyOriginal 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetReadOnlyOriginal() bool

func (*MigrationStreamingReadClientMessage_InitRequest) GetReadParams 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetReadParams() *ReadParams

func (*MigrationStreamingReadClientMessage_InitRequest) GetSessionId 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetSessionId() string

func (*MigrationStreamingReadClientMessage_InitRequest) GetStartFromWrittenAtMs 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetStartFromWrittenAtMs() int64

func (*MigrationStreamingReadClientMessage_InitRequest) GetState 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetState() *MigrationStreamingReadClientMessage_InitRequest_State

func (*MigrationStreamingReadClientMessage_InitRequest) GetTopicsReadSettings 

func (m *MigrationStreamingReadClientMessage_InitRequest) GetTopicsReadSettings() []*MigrationStreamingReadClientMessage_TopicReadSettings

func (*MigrationStreamingReadClientMessage_InitRequest) ProtoMessage 

func (*MigrationStreamingReadClientMessage_InitRequest) ProtoMessage()

func (*MigrationStreamingReadClientMessage_InitRequest) Reset 

func (m *MigrationStreamingReadClientMessage_InitRequest) Reset()

func (*MigrationStreamingReadClientMessage_InitRequest) String 

func (m *MigrationStreamingReadClientMessage_InitRequest) String() string

func (*MigrationStreamingReadClientMessage_InitRequest) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_InitRequest) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_InitRequest) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_InitRequest) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_InitRequest) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_InitRequest) XXX_Size 

func (m *MigrationStreamingReadClientMessage_InitRequest) XXX_Size() int

func (*MigrationStreamingReadClientMessage_InitRequest) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_InitRequest) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_InitRequest_ 

type MigrationStreamingReadClientMessage_InitRequest_ struct {
	InitRequest *MigrationStreamingReadClientMessage_InitRequest `protobuf:"bytes,1,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_InitRequest_State 

type MigrationStreamingReadClientMessage_InitRequest_State struct {
	PartitionStreamsStates []*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                                                                      `json:"-"`
	XXX_unrecognized       []byte                                                                        `json:"-"`
	XXX_sizecache          int32                                                                         `json:"-"`
}

State of client read session. Could be provided to server for retries.

func (*MigrationStreamingReadClientMessage_InitRequest_State) Descriptor 

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

func (*MigrationStreamingReadClientMessage_InitRequest_State) GetPartitionStreamsStates 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) GetPartitionStreamsStates() []*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState

func (*MigrationStreamingReadClientMessage_InitRequest_State) ProtoMessage 

func (*MigrationStreamingReadClientMessage_InitRequest_State) ProtoMessage()

func (*MigrationStreamingReadClientMessage_InitRequest_State) Reset 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) Reset()

func (*MigrationStreamingReadClientMessage_InitRequest_State) String 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) String() string

func (*MigrationStreamingReadClientMessage_InitRequest_State) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_InitRequest_State) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_InitRequest_State) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_InitRequest_State) XXX_Size 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) XXX_Size() int

func (*MigrationStreamingReadClientMessage_InitRequest_State) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_InitRequest_State) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState 

type MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState struct {
	// Partition partition stream.
	PartitionStream *PartitionStream `protobuf:"bytes,1,opt,name=partition_stream,json=partitionStream,proto3" json:"partition_stream,omitempty"`
	// Current read offset if has one. Actual for states DESTROYING, READING and STOPPED.
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Ranges of committed by client offsets.
	OffsetRanges []*OffsetsRange `protobuf:"bytes,3,rep,name=offset_ranges,json=offsetRanges,proto3" json:"offset_ranges,omitempty"`
	// Status of partition stream.
	Status               MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status `` /* 170-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                                          `json:"-"`
	XXX_unrecognized     []byte                                                                            `json:"-"`
	XXX_sizecache        int32                                                                             `json:"-"`
}

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) Descriptor 

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

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetOffsetRanges 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetOffsetRanges() []*OffsetsRange

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetPartitionStream 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetPartitionStream() *PartitionStream

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetReadOffset 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetReadOffset() int64

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetStatus 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) GetStatus() MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) ProtoMessage 

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) ProtoMessage()

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) Reset 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) Reset()

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) String 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) String() string

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Size 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Size() int

func (*MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status 

type MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status int32
const (
	// Not used state.
	MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_STATUS_UNSPECIFIED MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status = 0
	// Client seen Create message but not yet responded to server with Created message.
	MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_CREATING MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status = 1
	// Client seen Destroy message but not yet responded with Released message.
	MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_DESTROYING MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status = 2
	// Client sent Created or ResumeReadRequest message to server for this partition stream.
	MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_READING MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status = 3
	// Client sent StopReadRequest for this partition stream.
	MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_STOPPED MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status = 4
)

func (MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status) EnumDescriptor 

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

func (MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status) String 

func (x MigrationStreamingReadClientMessage_InitRequest_State_PartitionStreamState_Status) String() string

type MigrationStreamingReadClientMessage_Read 

type MigrationStreamingReadClientMessage_Read struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request of single read.

func (*MigrationStreamingReadClientMessage_Read) Descriptor 

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

func (*MigrationStreamingReadClientMessage_Read) ProtoMessage 

func (*MigrationStreamingReadClientMessage_Read) ProtoMessage()

func (*MigrationStreamingReadClientMessage_Read) Reset 

func (m *MigrationStreamingReadClientMessage_Read) Reset()

func (*MigrationStreamingReadClientMessage_Read) String 

func (m *MigrationStreamingReadClientMessage_Read) String() string

func (*MigrationStreamingReadClientMessage_Read) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_Read) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_Read) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_Read) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_Read) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_Read) XXX_Size 

func (m *MigrationStreamingReadClientMessage_Read) XXX_Size() int

func (*MigrationStreamingReadClientMessage_Read) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_Read) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_Read_ 

type MigrationStreamingReadClientMessage_Read_ struct {
	Read *MigrationStreamingReadClientMessage_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_Released 

type MigrationStreamingReadClientMessage_Released struct {
	// Topic path of partition.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Cluster of topic instance.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. Explicit only for debug purposes.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign identifier of Assign request from server. Used for mathing Assign requests from server with Released responses from client.
	AssignId             uint64   `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal for server that client finished working with this partition. Must be sent only after corresponding Release request from server. Server will give this partition to other read session only after Released signal.

func (*MigrationStreamingReadClientMessage_Released) Descriptor 

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

func (*MigrationStreamingReadClientMessage_Released) GetAssignId 

func (m *MigrationStreamingReadClientMessage_Released) GetAssignId() uint64

func (*MigrationStreamingReadClientMessage_Released) GetCluster 

func (m *MigrationStreamingReadClientMessage_Released) GetCluster() string

func (*MigrationStreamingReadClientMessage_Released) GetPartition 

func (m *MigrationStreamingReadClientMessage_Released) GetPartition() uint64

func (*MigrationStreamingReadClientMessage_Released) GetTopic 

func (m *MigrationStreamingReadClientMessage_Released) GetTopic() *Path

func (*MigrationStreamingReadClientMessage_Released) ProtoMessage 

func (*MigrationStreamingReadClientMessage_Released) ProtoMessage()

func (*MigrationStreamingReadClientMessage_Released) Reset 

func (m *MigrationStreamingReadClientMessage_Released) Reset()

func (*MigrationStreamingReadClientMessage_Released) String 

func (m *MigrationStreamingReadClientMessage_Released) String() string

func (*MigrationStreamingReadClientMessage_Released) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_Released) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_Released) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_Released) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_Released) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_Released) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_Released) XXX_Size 

func (m *MigrationStreamingReadClientMessage_Released) XXX_Size() int

func (*MigrationStreamingReadClientMessage_Released) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_Released) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_Released_ 

type MigrationStreamingReadClientMessage_Released_ struct {
	Released *MigrationStreamingReadClientMessage_Released `protobuf:"bytes,5,opt,name=released,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_StartRead 

type MigrationStreamingReadClientMessage_StartRead struct {
	// Topic path of partition.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Cluster of topic instance.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. Explicit only for debug purposes.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign identifier of Assign request from server. Used for mathing Assign requests from server with StartRead responses from client.
	AssignId uint64 `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	// Start reading from partition offset that is not less than read_offset.
	// ReadParams.max_time_lag_ms and ReadParams.read_timestamp_ms could lead to skip of more messages.
	// The same with actual committed offset. Regardless of set read_offset server will return data from maximal offset from read_offset, actual committed offset
	// and offsets calculated from ReadParams.max_time_lag_ms and ReadParams.read_timestamp_ms.
	ReadOffset uint64 `protobuf:"varint,6,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// All messages with offset less than commit_offset are processed by client. Server will commit this position if this is not done yet.
	CommitOffset uint64 `protobuf:"varint,7,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	// This option will enable sanity check on server for read_offset. Server will verify that read_offset is no less that actual committed offset.
	// If verification will fail then server will kill this read session and client will find out error in reading logic.
	// If client is not setting read_offset, sanity check will fail so do not set verify_read_offset if you not setting correct read_offset.
	VerifyReadOffset     bool     `protobuf:"varint,8,opt,name=verify_read_offset,json=verifyReadOffset,proto3" json:"verify_read_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MigrationStreamingReadClientMessage_StartRead) Descriptor 

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

func (*MigrationStreamingReadClientMessage_StartRead) GetAssignId 

func (m *MigrationStreamingReadClientMessage_StartRead) GetAssignId() uint64

func (*MigrationStreamingReadClientMessage_StartRead) GetCluster 

func (m *MigrationStreamingReadClientMessage_StartRead) GetCluster() string

func (*MigrationStreamingReadClientMessage_StartRead) GetCommitOffset 

func (m *MigrationStreamingReadClientMessage_StartRead) GetCommitOffset() uint64

func (*MigrationStreamingReadClientMessage_StartRead) GetPartition 

func (m *MigrationStreamingReadClientMessage_StartRead) GetPartition() uint64

func (*MigrationStreamingReadClientMessage_StartRead) GetReadOffset 

func (m *MigrationStreamingReadClientMessage_StartRead) GetReadOffset() uint64

func (*MigrationStreamingReadClientMessage_StartRead) GetTopic 

func (m *MigrationStreamingReadClientMessage_StartRead) GetTopic() *Path

func (*MigrationStreamingReadClientMessage_StartRead) GetVerifyReadOffset 

func (m *MigrationStreamingReadClientMessage_StartRead) GetVerifyReadOffset() bool

func (*MigrationStreamingReadClientMessage_StartRead) ProtoMessage 

func (*MigrationStreamingReadClientMessage_StartRead) ProtoMessage()

func (*MigrationStreamingReadClientMessage_StartRead) Reset 

func (m *MigrationStreamingReadClientMessage_StartRead) Reset()

func (*MigrationStreamingReadClientMessage_StartRead) String 

func (m *MigrationStreamingReadClientMessage_StartRead) String() string

func (*MigrationStreamingReadClientMessage_StartRead) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_StartRead) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_StartRead) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_StartRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_StartRead) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_StartRead) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_StartRead) XXX_Size 

func (m *MigrationStreamingReadClientMessage_StartRead) XXX_Size() int

func (*MigrationStreamingReadClientMessage_StartRead) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_StartRead) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_StartRead_ 

type MigrationStreamingReadClientMessage_StartRead_ struct {
	StartRead *MigrationStreamingReadClientMessage_StartRead `protobuf:"bytes,3,opt,name=start_read,json=startRead,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_Status 

type MigrationStreamingReadClientMessage_Status struct {
	// Topic path of partition.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Cluster of topic instance.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. Explicit only for debug purposes.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign identifier of Assign request from server. Used for mathing Assign requests from server with Released responses from client.
	AssignId             uint64   `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MigrationStreamingReadClientMessage_Status) Descriptor 

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

func (*MigrationStreamingReadClientMessage_Status) GetAssignId 

func (m *MigrationStreamingReadClientMessage_Status) GetAssignId() uint64

func (*MigrationStreamingReadClientMessage_Status) GetCluster 

func (m *MigrationStreamingReadClientMessage_Status) GetCluster() string

func (*MigrationStreamingReadClientMessage_Status) GetPartition 

func (m *MigrationStreamingReadClientMessage_Status) GetPartition() uint64

func (*MigrationStreamingReadClientMessage_Status) GetTopic 

func (m *MigrationStreamingReadClientMessage_Status) GetTopic() *Path

func (*MigrationStreamingReadClientMessage_Status) ProtoMessage 

func (*MigrationStreamingReadClientMessage_Status) ProtoMessage()

func (*MigrationStreamingReadClientMessage_Status) Reset 

func (m *MigrationStreamingReadClientMessage_Status) Reset()

func (*MigrationStreamingReadClientMessage_Status) String 

func (m *MigrationStreamingReadClientMessage_Status) String() string

func (*MigrationStreamingReadClientMessage_Status) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_Status) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_Status) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_Status) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_Status) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_Status) XXX_Size 

func (m *MigrationStreamingReadClientMessage_Status) XXX_Size() int

func (*MigrationStreamingReadClientMessage_Status) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_Status) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadClientMessage_Status_ 

type MigrationStreamingReadClientMessage_Status_ struct {
	Status *MigrationStreamingReadClientMessage_Status `protobuf:"bytes,6,opt,name=status,proto3,oneof"`
}

type MigrationStreamingReadClientMessage_TopicReadSettings 

type MigrationStreamingReadClientMessage_TopicReadSettings struct {
	// Topic path.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Partition groups that will be read by this session.
	// If list is empty - then session will read all partition groups.
	PartitionGroupIds []int64 `protobuf:"varint,2,rep,packed,name=partition_group_ids,json=partitionGroupIds,proto3" json:"partition_group_ids,omitempty"`
	// Read data only after this timestamp from this topic.
	StartFromWrittenAtMs int64    `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MigrationStreamingReadClientMessage_TopicReadSettings) Descriptor 

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

func (*MigrationStreamingReadClientMessage_TopicReadSettings) GetPartitionGroupIds 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) GetPartitionGroupIds() []int64

func (*MigrationStreamingReadClientMessage_TopicReadSettings) GetStartFromWrittenAtMs 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) GetStartFromWrittenAtMs() int64

func (*MigrationStreamingReadClientMessage_TopicReadSettings) GetTopic 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) GetTopic() string

func (*MigrationStreamingReadClientMessage_TopicReadSettings) ProtoMessage 

func (*MigrationStreamingReadClientMessage_TopicReadSettings) ProtoMessage()

func (*MigrationStreamingReadClientMessage_TopicReadSettings) Reset 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) Reset()

func (*MigrationStreamingReadClientMessage_TopicReadSettings) String 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) String() string

func (*MigrationStreamingReadClientMessage_TopicReadSettings) XXX_DiscardUnknown 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) XXX_DiscardUnknown()

func (*MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Marshal 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Merge 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Size 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Size() int

func (*MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Unmarshal 

func (m *MigrationStreamingReadClientMessage_TopicReadSettings) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage 

type MigrationStreamingReadServerMessage struct {
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*MigrationStreamingReadServerMessage_InitResponse_
	//	*MigrationStreamingReadServerMessage_DataBatch_
	//	*MigrationStreamingReadServerMessage_Assigned_
	//	*MigrationStreamingReadServerMessage_Release_
	//	*MigrationStreamingReadServerMessage_Committed_
	//	*MigrationStreamingReadServerMessage_PartitionStatus_
	Response             isMigrationStreamingReadServerMessage_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*MigrationStreamingReadServerMessage) Descriptor 

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

func (*MigrationStreamingReadServerMessage) GetAssigned 

func (m *MigrationStreamingReadServerMessage) GetAssigned() *MigrationStreamingReadServerMessage_Assigned

func (*MigrationStreamingReadServerMessage) GetCommitted 

func (m *MigrationStreamingReadServerMessage) GetCommitted() *MigrationStreamingReadServerMessage_Committed

func (*MigrationStreamingReadServerMessage) GetDataBatch 

func (m *MigrationStreamingReadServerMessage) GetDataBatch() *MigrationStreamingReadServerMessage_DataBatch

func (*MigrationStreamingReadServerMessage) GetInitResponse 

func (m *MigrationStreamingReadServerMessage) GetInitResponse() *MigrationStreamingReadServerMessage_InitResponse

func (*MigrationStreamingReadServerMessage) GetIssues 

func (m *MigrationStreamingReadServerMessage) GetIssues() []*Ydb_Issue.IssueMessage

func (*MigrationStreamingReadServerMessage) GetPartitionStatus 

func (m *MigrationStreamingReadServerMessage) GetPartitionStatus() *MigrationStreamingReadServerMessage_PartitionStatus

func (*MigrationStreamingReadServerMessage) GetRelease 

func (m *MigrationStreamingReadServerMessage) GetRelease() *MigrationStreamingReadServerMessage_Release

func (*MigrationStreamingReadServerMessage) GetResponse 

func (m *MigrationStreamingReadServerMessage) GetResponse() isMigrationStreamingReadServerMessage_Response

func (*MigrationStreamingReadServerMessage) GetStatus 

func (m *MigrationStreamingReadServerMessage) GetStatus() Ydb.StatusIds_StatusCode

func (*MigrationStreamingReadServerMessage) ProtoMessage 

func (*MigrationStreamingReadServerMessage) ProtoMessage()

func (*MigrationStreamingReadServerMessage) Reset 

func (m *MigrationStreamingReadServerMessage) Reset()

func (*MigrationStreamingReadServerMessage) String 

func (m *MigrationStreamingReadServerMessage) String() string

func (*MigrationStreamingReadServerMessage) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage) XXX_Merge 

func (m *MigrationStreamingReadServerMessage) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage) XXX_OneofWrappers 

func (*MigrationStreamingReadServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MigrationStreamingReadServerMessage) XXX_Size 

func (m *MigrationStreamingReadServerMessage) XXX_Size() int

func (*MigrationStreamingReadServerMessage) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_Assigned 

type MigrationStreamingReadServerMessage_Assigned struct {
	// Partition's topic path.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Topic's instance cluster name.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. topic:cluster:partition is unique addressing of partition.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign idenfier. Is not unique between diffrent partitions. Used for matching Assigned request from server and StartRead response from client.
	AssignId uint64 `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	// Actual read offset. Equeal to last committed offset.
	ReadOffset uint64 `protobuf:"varint,6,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Offset of first not existing message in partition at this time.
	EndOffset            uint64   `protobuf:"varint,7,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal that partition is assigned to this read session. Client must react on this signal by sending StartRead when ready.

func (*MigrationStreamingReadServerMessage_Assigned) Descriptor 

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

func (*MigrationStreamingReadServerMessage_Assigned) GetAssignId 

func (m *MigrationStreamingReadServerMessage_Assigned) GetAssignId() uint64

func (*MigrationStreamingReadServerMessage_Assigned) GetCluster 

func (m *MigrationStreamingReadServerMessage_Assigned) GetCluster() string

func (*MigrationStreamingReadServerMessage_Assigned) GetEndOffset 

func (m *MigrationStreamingReadServerMessage_Assigned) GetEndOffset() uint64

func (*MigrationStreamingReadServerMessage_Assigned) GetPartition 

func (m *MigrationStreamingReadServerMessage_Assigned) GetPartition() uint64

func (*MigrationStreamingReadServerMessage_Assigned) GetReadOffset 

func (m *MigrationStreamingReadServerMessage_Assigned) GetReadOffset() uint64

func (*MigrationStreamingReadServerMessage_Assigned) GetTopic 

func (m *MigrationStreamingReadServerMessage_Assigned) GetTopic() *Path

func (*MigrationStreamingReadServerMessage_Assigned) ProtoMessage 

func (*MigrationStreamingReadServerMessage_Assigned) ProtoMessage()

func (*MigrationStreamingReadServerMessage_Assigned) Reset 

func (m *MigrationStreamingReadServerMessage_Assigned) Reset()

func (*MigrationStreamingReadServerMessage_Assigned) String 

func (m *MigrationStreamingReadServerMessage_Assigned) String() string

func (*MigrationStreamingReadServerMessage_Assigned) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_Assigned) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_Assigned) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_Assigned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_Assigned) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_Assigned) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_Assigned) XXX_Size 

func (m *MigrationStreamingReadServerMessage_Assigned) XXX_Size() int

func (*MigrationStreamingReadServerMessage_Assigned) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_Assigned) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_Assigned_ 

type MigrationStreamingReadServerMessage_Assigned_ struct {
	Assigned *MigrationStreamingReadServerMessage_Assigned `protobuf:"bytes,5,opt,name=assigned,proto3,oneof"`
}

type MigrationStreamingReadServerMessage_Committed 

type MigrationStreamingReadServerMessage_Committed struct {
	// List of cookies that correspond to commit of processing read data.
	Cookies              []*CommitCookie      `protobuf:"bytes,1,rep,name=cookies,proto3" json:"cookies,omitempty"`
	OffsetRanges         []*CommitOffsetRange `protobuf:"bytes,2,rep,name=offset_ranges,json=offsetRanges,proto3" json:"offset_ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Acknowledgement for commits.

func (*MigrationStreamingReadServerMessage_Committed) Descriptor 

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

func (*MigrationStreamingReadServerMessage_Committed) GetCookies 

func (m *MigrationStreamingReadServerMessage_Committed) GetCookies() []*CommitCookie

func (*MigrationStreamingReadServerMessage_Committed) GetOffsetRanges 

func (m *MigrationStreamingReadServerMessage_Committed) GetOffsetRanges() []*CommitOffsetRange

func (*MigrationStreamingReadServerMessage_Committed) ProtoMessage 

func (*MigrationStreamingReadServerMessage_Committed) ProtoMessage()

func (*MigrationStreamingReadServerMessage_Committed) Reset 

func (m *MigrationStreamingReadServerMessage_Committed) Reset()

func (*MigrationStreamingReadServerMessage_Committed) String 

func (m *MigrationStreamingReadServerMessage_Committed) String() string

func (*MigrationStreamingReadServerMessage_Committed) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_Committed) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_Committed) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_Committed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_Committed) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_Committed) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_Committed) XXX_Size 

func (m *MigrationStreamingReadServerMessage_Committed) XXX_Size() int

func (*MigrationStreamingReadServerMessage_Committed) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_Committed) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_Committed_ 

type MigrationStreamingReadServerMessage_Committed_ struct {
	Committed *MigrationStreamingReadServerMessage_Committed `protobuf:"bytes,7,opt,name=committed,proto3,oneof"`
}

type MigrationStreamingReadServerMessage_DataBatch 

type MigrationStreamingReadServerMessage_DataBatch struct {
	// Client messages, divided by partitions.
	PartitionData        []*MigrationStreamingReadServerMessage_DataBatch_PartitionData `protobuf:"bytes,1,rep,name=partition_data,json=partitionData,proto3" json:"partition_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                                       `json:"-"`
	XXX_unrecognized     []byte                                                         `json:"-"`
	XXX_sizecache        int32                                                          `json:"-"`
}

Readed data.

func (*MigrationStreamingReadServerMessage_DataBatch) Descriptor 

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

func (*MigrationStreamingReadServerMessage_DataBatch) GetPartitionData 

func (m *MigrationStreamingReadServerMessage_DataBatch) GetPartitionData() []*MigrationStreamingReadServerMessage_DataBatch_PartitionData

func (*MigrationStreamingReadServerMessage_DataBatch) ProtoMessage 

func (*MigrationStreamingReadServerMessage_DataBatch) ProtoMessage()

func (*MigrationStreamingReadServerMessage_DataBatch) Reset 

func (m *MigrationStreamingReadServerMessage_DataBatch) Reset()

func (*MigrationStreamingReadServerMessage_DataBatch) String 

func (m *MigrationStreamingReadServerMessage_DataBatch) String() string

func (*MigrationStreamingReadServerMessage_DataBatch) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_DataBatch) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_DataBatch) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_DataBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_DataBatch) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_DataBatch) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_DataBatch) XXX_Size 

func (m *MigrationStreamingReadServerMessage_DataBatch) XXX_Size() int

func (*MigrationStreamingReadServerMessage_DataBatch) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_DataBatch) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_DataBatch_ 

type MigrationStreamingReadServerMessage_DataBatch_ struct {
	DataBatch *MigrationStreamingReadServerMessage_DataBatch `protobuf:"bytes,4,opt,name=data_batch,json=dataBatch,proto3,oneof"`
}

type MigrationStreamingReadServerMessage_DataBatch_Batch 

type MigrationStreamingReadServerMessage_DataBatch_Batch struct {
	// Source identifier provided by client for this batch of client messages.
	SourceId []byte `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	// Client metadata attached to write session, the same for all messages in batch.
	ExtraFields []*KeyValue `protobuf:"bytes,3,rep,name=extra_fields,json=extraFields,proto3" json:"extra_fields,omitempty"`
	// Persist timestamp on server for batch.
	WriteTimestampMs uint64 `protobuf:"varint,4,opt,name=write_timestamp_ms,json=writeTimestampMs,proto3" json:"write_timestamp_ms,omitempty"`
	// Peer address of node that created write session.
	Ip string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	// List of client messages.
	MessageData          []*MigrationStreamingReadServerMessage_DataBatch_MessageData `protobuf:"bytes,1,rep,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                                     `json:"-"`
	XXX_unrecognized     []byte                                                       `json:"-"`
	XXX_sizecache        int32                                                        `json:"-"`
}

Representation of sequence of client messages from one write session.

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) Descriptor 

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

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) GetExtraFields 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) GetExtraFields() []*KeyValue

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) GetIp 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) GetIp() string

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) GetMessageData 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) GetMessageData() []*MigrationStreamingReadServerMessage_DataBatch_MessageData

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) GetSourceId 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) GetSourceId() []byte

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) GetWriteTimestampMs 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) GetWriteTimestampMs() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) ProtoMessage 

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) ProtoMessage()

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) Reset 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) Reset()

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) String 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) String() string

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Size 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Size() int

func (*MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_Batch) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_DataBatch_MessageData 

type MigrationStreamingReadServerMessage_DataBatch_MessageData struct {
	// Partition offset in partition that assigned for message.
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// Sequence number that provided with message on write from client.
	SeqNo uint64 `protobuf:"varint,2,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	// Timestamp of creation of message provided on write from client.
	CreateTimestampMs uint64 `protobuf:"varint,3,opt,name=create_timestamp_ms,json=createTimestampMs,proto3" json:"create_timestamp_ms,omitempty"`
	// Codec that is used for data compressing.
	Codec Codec `protobuf:"varint,4,opt,name=codec,proto3,enum=Ydb.PersQueue.V1.Codec" json:"codec,omitempty"`
	// Compressed client message body.
	Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// Uncompressed size of client message body.
	UncompressedSize uint64 `protobuf:"varint,6,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
	// kinesis data
	PartitionKey         string   `protobuf:"bytes,7,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	ExplicitHash         []byte   `protobuf:"bytes,8,opt,name=explicit_hash,json=explicitHash,proto3" json:"explicit_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

One client message representation.

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) Descriptor 

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

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetCodec 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetCodec() Codec

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetCreateTimestampMs 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetCreateTimestampMs() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetData 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetData() []byte

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetExplicitHash 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetExplicitHash() []byte

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetOffset 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetOffset() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetPartitionKey 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetPartitionKey() string

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetSeqNo 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetSeqNo() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) GetUncompressedSize 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) GetUncompressedSize() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) ProtoMessage 

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) ProtoMessage()

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) Reset 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) Reset()

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) String 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) String() string

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Size 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Size() int

func (*MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_MessageData) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_DataBatch_PartitionData 

type MigrationStreamingReadServerMessage_DataBatch_PartitionData struct {
	// Partition's topic path.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Topic's instance cluster name.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. topic:cluster:partition is unique addressing for partition.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Client messages, divided by write sessions.
	Batches []*MigrationStreamingReadServerMessage_DataBatch_Batch `protobuf:"bytes,4,rep,name=batches,proto3" json:"batches,omitempty"`
	// Cookie for addressing this partition messages batch for committing.
	Cookie *CommitCookie `protobuf:"bytes,5,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// Old formatted topic name with cluster inside.
	DeprecatedTopic      string   `protobuf:"bytes,10,opt,name=deprecated_topic,json=deprecatedTopic,proto3" json:"deprecated_topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Representation of sequence of messages from one partition.

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) Descriptor 

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

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetBatches 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetBatches() []*MigrationStreamingReadServerMessage_DataBatch_Batch

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetCluster 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetCluster() string

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetCookie 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetCookie() *CommitCookie

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetDeprecatedTopic 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetDeprecatedTopic() string

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetPartition 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetPartition() uint64

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetTopic 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) GetTopic() *Path

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) ProtoMessage 

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) ProtoMessage()

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) Reset 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) Reset()

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) String 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) String() string

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Size 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Size() int

func (*MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_DataBatch_PartitionData) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_InitResponse 

type MigrationStreamingReadServerMessage_InitResponse struct {
	// Read session identifier for debug purposes.
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Block format version of data client will receive from topics.
	BlockFormatVersionByTopic map[string]int64 `` /* 231-byte string literal not displayed */
	// Choosed maximan cache size by server.
	// Client must use cache of this size. Could change on retries - reduce size of cache in this case.
	MaxMetaCacheSize     int64    `protobuf:"varint,10,opt,name=max_meta_cache_size,json=maxMetaCacheSize,proto3" json:"max_meta_cache_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Handshake response.

func (*MigrationStreamingReadServerMessage_InitResponse) Descriptor 

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

func (*MigrationStreamingReadServerMessage_InitResponse) GetBlockFormatVersionByTopic 

func (m *MigrationStreamingReadServerMessage_InitResponse) GetBlockFormatVersionByTopic() map[string]int64

func (*MigrationStreamingReadServerMessage_InitResponse) GetMaxMetaCacheSize 

func (m *MigrationStreamingReadServerMessage_InitResponse) GetMaxMetaCacheSize() int64

func (*MigrationStreamingReadServerMessage_InitResponse) GetSessionId 

func (m *MigrationStreamingReadServerMessage_InitResponse) GetSessionId() string

func (*MigrationStreamingReadServerMessage_InitResponse) ProtoMessage 

func (*MigrationStreamingReadServerMessage_InitResponse) ProtoMessage()

func (*MigrationStreamingReadServerMessage_InitResponse) Reset 

func (m *MigrationStreamingReadServerMessage_InitResponse) Reset()

func (*MigrationStreamingReadServerMessage_InitResponse) String 

func (m *MigrationStreamingReadServerMessage_InitResponse) String() string

func (*MigrationStreamingReadServerMessage_InitResponse) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_InitResponse) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_InitResponse) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_InitResponse) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_InitResponse) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_InitResponse) XXX_Size 

func (m *MigrationStreamingReadServerMessage_InitResponse) XXX_Size() int

func (*MigrationStreamingReadServerMessage_InitResponse) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_InitResponse) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_InitResponse_ 

type MigrationStreamingReadServerMessage_InitResponse_ struct {
	InitResponse *MigrationStreamingReadServerMessage_InitResponse `protobuf:"bytes,3,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type MigrationStreamingReadServerMessage_PartitionStatus 

type MigrationStreamingReadServerMessage_PartitionStatus struct {
	// Partition's topic path.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Topic's instance cluster name.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. topic:cluster:partition is unique addressing of partition.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign idenfier. Used for matching Assigned and Release requests from server.
	AssignId             uint64   `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	CommittedOffset      uint64   `protobuf:"varint,6,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	EndOffset            uint64   `protobuf:"varint,7,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	WriteWatermarkMs     uint64   `protobuf:"varint,8,opt,name=write_watermark_ms,json=writeWatermarkMs,proto3" json:"write_watermark_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for status requst.

func (*MigrationStreamingReadServerMessage_PartitionStatus) Descriptor 

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

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetAssignId 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetAssignId() uint64

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetCluster 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetCluster() string

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetCommittedOffset 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetCommittedOffset() uint64

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetEndOffset 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetEndOffset() uint64

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetPartition 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetPartition() uint64

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetTopic 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetTopic() *Path

func (*MigrationStreamingReadServerMessage_PartitionStatus) GetWriteWatermarkMs 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) GetWriteWatermarkMs() uint64

func (*MigrationStreamingReadServerMessage_PartitionStatus) ProtoMessage 

func (*MigrationStreamingReadServerMessage_PartitionStatus) ProtoMessage()

func (*MigrationStreamingReadServerMessage_PartitionStatus) Reset 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) Reset()

func (*MigrationStreamingReadServerMessage_PartitionStatus) String 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) String() string

func (*MigrationStreamingReadServerMessage_PartitionStatus) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_PartitionStatus) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_PartitionStatus) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_PartitionStatus) XXX_Size 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) XXX_Size() int

func (*MigrationStreamingReadServerMessage_PartitionStatus) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_PartitionStatus) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_PartitionStatus_ 

type MigrationStreamingReadServerMessage_PartitionStatus_ struct {
	PartitionStatus *MigrationStreamingReadServerMessage_PartitionStatus `protobuf:"bytes,8,opt,name=partition_status,json=partitionStatus,proto3,oneof"`
}

type MigrationStreamingReadServerMessage_Release 

type MigrationStreamingReadServerMessage_Release struct {
	// Partition's topic path.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Topic's instance cluster name.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. topic:cluster:partition is unique addressing of partition.
	Partition uint64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// Assign idenfier. Used for matching Assigned and Release requests from server.
	AssignId uint64 `protobuf:"varint,5,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	// If False then server is waiting for Released signal from client before giving of this partition for other read session.
	// If True then server gives partition for other session right now. All futher commits for this partition has no effect. Server is not waiting for Released signal.
	ForcefulRelease bool `protobuf:"varint,6,opt,name=forceful_release,json=forcefulRelease,proto3" json:"forceful_release,omitempty"`
	// Last known committed offset.
	CommitOffset         uint64   `protobuf:"varint,7,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Partition release request from server.

func (*MigrationStreamingReadServerMessage_Release) Descriptor 

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

func (*MigrationStreamingReadServerMessage_Release) GetAssignId 

func (m *MigrationStreamingReadServerMessage_Release) GetAssignId() uint64

func (*MigrationStreamingReadServerMessage_Release) GetCluster 

func (m *MigrationStreamingReadServerMessage_Release) GetCluster() string

func (*MigrationStreamingReadServerMessage_Release) GetCommitOffset 

func (m *MigrationStreamingReadServerMessage_Release) GetCommitOffset() uint64

func (*MigrationStreamingReadServerMessage_Release) GetForcefulRelease 

func (m *MigrationStreamingReadServerMessage_Release) GetForcefulRelease() bool

func (*MigrationStreamingReadServerMessage_Release) GetPartition 

func (m *MigrationStreamingReadServerMessage_Release) GetPartition() uint64

func (*MigrationStreamingReadServerMessage_Release) GetTopic 

func (m *MigrationStreamingReadServerMessage_Release) GetTopic() *Path

func (*MigrationStreamingReadServerMessage_Release) ProtoMessage 

func (*MigrationStreamingReadServerMessage_Release) ProtoMessage()

func (*MigrationStreamingReadServerMessage_Release) Reset 

func (m *MigrationStreamingReadServerMessage_Release) Reset()

func (*MigrationStreamingReadServerMessage_Release) String 

func (m *MigrationStreamingReadServerMessage_Release) String() string

func (*MigrationStreamingReadServerMessage_Release) XXX_DiscardUnknown 

func (m *MigrationStreamingReadServerMessage_Release) XXX_DiscardUnknown()

func (*MigrationStreamingReadServerMessage_Release) XXX_Marshal 

func (m *MigrationStreamingReadServerMessage_Release) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStreamingReadServerMessage_Release) XXX_Merge 

func (m *MigrationStreamingReadServerMessage_Release) XXX_Merge(src proto.Message)

func (*MigrationStreamingReadServerMessage_Release) XXX_Size 

func (m *MigrationStreamingReadServerMessage_Release) XXX_Size() int

func (*MigrationStreamingReadServerMessage_Release) XXX_Unmarshal 

func (m *MigrationStreamingReadServerMessage_Release) XXX_Unmarshal(b []byte) error

type MigrationStreamingReadServerMessage_Release_ 

type MigrationStreamingReadServerMessage_Release_ struct {
	Release *MigrationStreamingReadServerMessage_Release `protobuf:"bytes,6,opt,name=release,proto3,oneof"`
}

type OffsetsRange 

type OffsetsRange struct {
	StartOffset          int64    `protobuf:"varint,1,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset            int64    `protobuf:"varint,2,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Represents range [start_offset, end_offset).

func (*OffsetsRange) Descriptor 

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

func (*OffsetsRange) GetEndOffset 

func (m *OffsetsRange) GetEndOffset() int64

func (*OffsetsRange) GetStartOffset 

func (m *OffsetsRange) GetStartOffset() int64

func (*OffsetsRange) ProtoMessage 

func (*OffsetsRange) ProtoMessage()

func (*OffsetsRange) Reset 

func (m *OffsetsRange) Reset()

func (*OffsetsRange) String 

func (m *OffsetsRange) String() string

func (*OffsetsRange) XXX_DiscardUnknown 

func (m *OffsetsRange) XXX_DiscardUnknown()

func (*OffsetsRange) XXX_Marshal 

func (m *OffsetsRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OffsetsRange) XXX_Merge 

func (m *OffsetsRange) XXX_Merge(src proto.Message)

func (*OffsetsRange) XXX_Size 

func (m *OffsetsRange) XXX_Size() int

func (*OffsetsRange) XXX_Unmarshal 

func (m *OffsetsRange) XXX_Unmarshal(b []byte) error

type PartitionStream 

type PartitionStream struct {
	// Topic path of partition.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Cluster of topic instance.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Partition identifier. Explicit only for debug purposes.
	PartitionId int64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Partition group identifier. Explicit only for debug purposes.
	PartitionGroupId int64 `protobuf:"varint,4,opt,name=partition_group_id,json=partitionGroupId,proto3" json:"partition_group_id,omitempty"`
	// Identitifier of partition stream. Unique inside one RPC call.
	PartitionStreamId int64 `protobuf:"varint,6,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Opaque blob. Provide it with partition stream in state for session reconnects.
	ConnectionMeta       []byte   `protobuf:"bytes,7,opt,name=connection_meta,json=connectionMeta,proto3" json:"connection_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Message that represens concrete partition partition stream.

func (*PartitionStream) Descriptor 

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

func (*PartitionStream) GetCluster 

func (m *PartitionStream) GetCluster() string

func (*PartitionStream) GetConnectionMeta 

func (m *PartitionStream) GetConnectionMeta() []byte

func (*PartitionStream) GetPartitionGroupId 

func (m *PartitionStream) GetPartitionGroupId() int64

func (*PartitionStream) GetPartitionId 

func (m *PartitionStream) GetPartitionId() int64

func (*PartitionStream) GetPartitionStreamId 

func (m *PartitionStream) GetPartitionStreamId() int64

func (*PartitionStream) GetTopic 

func (m *PartitionStream) GetTopic() string

func (*PartitionStream) ProtoMessage 

func (*PartitionStream) ProtoMessage()

func (*PartitionStream) Reset 

func (m *PartitionStream) Reset()

func (*PartitionStream) String 

func (m *PartitionStream) String() string

func (*PartitionStream) XXX_DiscardUnknown 

func (m *PartitionStream) XXX_DiscardUnknown()

func (*PartitionStream) XXX_Marshal 

func (m *PartitionStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionStream) XXX_Merge 

func (m *PartitionStream) XXX_Merge(src proto.Message)

func (*PartitionStream) XXX_Size 

func (m *PartitionStream) XXX_Size() int

func (*PartitionStream) XXX_Unmarshal 

func (m *PartitionStream) XXX_Unmarshal(b []byte) error

type Path 

type Path struct {
	// Path of object (topic/consumer).
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Path) Descriptor 

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

func (*Path) GetPath 

func (m *Path) GetPath() string

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) Reset 

func (m *Path) Reset()

func (*Path) String 

func (m *Path) String() string

func (*Path) XXX_DiscardUnknown 

func (m *Path) XXX_DiscardUnknown()

func (*Path) XXX_Marshal 

func (m *Path) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Path) XXX_Merge 

func (m *Path) XXX_Merge(src proto.Message)

func (*Path) XXX_Size 

func (m *Path) XXX_Size() int

func (*Path) XXX_Unmarshal 

func (m *Path) XXX_Unmarshal(b []byte) error

type ReadInfoRequest 

type ReadInfoRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// List of topics that are beeing read.
	Topics []*Path `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	// If get_only_original == false then return info about mirrored topics too.
	GetOnlyOriginal bool `protobuf:"varint,3,opt,name=get_only_original,json=getOnlyOriginal,proto3" json:"get_only_original,omitempty"`
	// Consumer path that is reading specified topics.
	Consumer             *Path    `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadInfoRequest) Descriptor 

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

func (*ReadInfoRequest) GetConsumer 

func (m *ReadInfoRequest) GetConsumer() *Path

func (*ReadInfoRequest) GetGetOnlyOriginal 

func (m *ReadInfoRequest) GetGetOnlyOriginal() bool

func (*ReadInfoRequest) GetOperationParams 

func (m *ReadInfoRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ReadInfoRequest) GetTopics 

func (m *ReadInfoRequest) GetTopics() []*Path

func (*ReadInfoRequest) ProtoMessage 

func (*ReadInfoRequest) ProtoMessage()

func (*ReadInfoRequest) Reset 

func (m *ReadInfoRequest) Reset()

func (*ReadInfoRequest) SetOperationParams 

func (m *ReadInfoRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ReadInfoRequest) String 

func (m *ReadInfoRequest) String() string

func (*ReadInfoRequest) XXX_DiscardUnknown 

func (m *ReadInfoRequest) XXX_DiscardUnknown()

func (*ReadInfoRequest) XXX_Marshal 

func (m *ReadInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInfoRequest) XXX_Merge 

func (m *ReadInfoRequest) XXX_Merge(src proto.Message)

func (*ReadInfoRequest) XXX_Size 

func (m *ReadInfoRequest) XXX_Size() int

func (*ReadInfoRequest) XXX_Unmarshal 

func (m *ReadInfoRequest) XXX_Unmarshal(b []byte) error

type ReadInfoResponse 

type ReadInfoResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ReadInfoResponse) Descriptor 

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

func (*ReadInfoResponse) GetOperation 

func (m *ReadInfoResponse) GetOperation() *Ydb_Operations.Operation

func (*ReadInfoResponse) ProtoMessage 

func (*ReadInfoResponse) ProtoMessage()

func (*ReadInfoResponse) Reset 

func (m *ReadInfoResponse) Reset()

func (*ReadInfoResponse) String 

func (m *ReadInfoResponse) String() string

func (*ReadInfoResponse) XXX_DiscardUnknown 

func (m *ReadInfoResponse) XXX_DiscardUnknown()

func (*ReadInfoResponse) XXX_Marshal 

func (m *ReadInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInfoResponse) XXX_Merge 

func (m *ReadInfoResponse) XXX_Merge(src proto.Message)

func (*ReadInfoResponse) XXX_Size 

func (m *ReadInfoResponse) XXX_Size() int

func (*ReadInfoResponse) XXX_Unmarshal 

func (m *ReadInfoResponse) XXX_Unmarshal(b []byte) error

type ReadInfoResult 

type ReadInfoResult struct {
	// List of topics info.
	Topics               []*ReadInfoResult_TopicInfo `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ReadInfoResult) Descriptor 

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

func (*ReadInfoResult) GetTopics 

func (m *ReadInfoResult) GetTopics() []*ReadInfoResult_TopicInfo

func (*ReadInfoResult) ProtoMessage 

func (*ReadInfoResult) ProtoMessage()

func (*ReadInfoResult) Reset 

func (m *ReadInfoResult) Reset()

func (*ReadInfoResult) String 

func (m *ReadInfoResult) String() string

func (*ReadInfoResult) XXX_DiscardUnknown 

func (m *ReadInfoResult) XXX_DiscardUnknown()

func (*ReadInfoResult) XXX_Marshal 

func (m *ReadInfoResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInfoResult) XXX_Merge 

func (m *ReadInfoResult) XXX_Merge(src proto.Message)

func (*ReadInfoResult) XXX_Size 

func (m *ReadInfoResult) XXX_Size() int

func (*ReadInfoResult) XXX_Unmarshal 

func (m *ReadInfoResult) XXX_Unmarshal(b []byte) error

type ReadInfoResult_TopicInfo 

type ReadInfoResult_TopicInfo struct {
	// Topic path.
	Topic *Path `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Topic original cluster.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Status of whole topic.
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,3,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues if any.
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,4,rep,name=issues,proto3" json:"issues,omitempty"`
	// Reading info for partitions of this topic.
	Partitions           []*ReadInfoResult_TopicInfo_PartitionInfo `protobuf:"bytes,5,rep,name=partitions,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

Message containing information about concrete topic reading.

func (*ReadInfoResult_TopicInfo) Descriptor 

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

func (*ReadInfoResult_TopicInfo) GetCluster 

func (m *ReadInfoResult_TopicInfo) GetCluster() string

func (*ReadInfoResult_TopicInfo) GetIssues 

func (m *ReadInfoResult_TopicInfo) GetIssues() []*Ydb_Issue.IssueMessage

func (*ReadInfoResult_TopicInfo) GetPartitions 

func (m *ReadInfoResult_TopicInfo) GetPartitions() []*ReadInfoResult_TopicInfo_PartitionInfo

func (*ReadInfoResult_TopicInfo) GetStatus 

func (m *ReadInfoResult_TopicInfo) GetStatus() Ydb.StatusIds_StatusCode

func (*ReadInfoResult_TopicInfo) GetTopic 

func (m *ReadInfoResult_TopicInfo) GetTopic() *Path

func (*ReadInfoResult_TopicInfo) ProtoMessage 

func (*ReadInfoResult_TopicInfo) ProtoMessage()

func (*ReadInfoResult_TopicInfo) Reset 

func (m *ReadInfoResult_TopicInfo) Reset()

func (*ReadInfoResult_TopicInfo) String 

func (m *ReadInfoResult_TopicInfo) String() string

func (*ReadInfoResult_TopicInfo) XXX_DiscardUnknown 

func (m *ReadInfoResult_TopicInfo) XXX_DiscardUnknown()

func (*ReadInfoResult_TopicInfo) XXX_Marshal 

func (m *ReadInfoResult_TopicInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInfoResult_TopicInfo) XXX_Merge 

func (m *ReadInfoResult_TopicInfo) XXX_Merge(src proto.Message)

func (*ReadInfoResult_TopicInfo) XXX_Size 

func (m *ReadInfoResult_TopicInfo) XXX_Size() int

func (*ReadInfoResult_TopicInfo) XXX_Unmarshal 

func (m *ReadInfoResult_TopicInfo) XXX_Unmarshal(b []byte) error

type ReadInfoResult_TopicInfo_PartitionInfo 

type ReadInfoResult_TopicInfo_PartitionInfo struct {
	// Patition identifier inside topic.
	Partition uint64 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// Request status of partition.
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues if any.
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// Offset of first message in partition.
	StartOffset uint64 `protobuf:"varint,4,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	// Offset of next not yet existing message in partition.
	EndOffset uint64 `protobuf:"varint,5,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	// Offset of consumer committed message a.k.a. first not processed message.
	// If commit_offset == end_offset then all messages from partition are processed.
	CommitOffset uint64 `protobuf:"varint,6,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	// Consumer lag in time between committed and last messages in partition.
	CommitTimeLagMs uint64 `protobuf:"varint,7,opt,name=commit_time_lag_ms,json=commitTimeLagMs,proto3" json:"commit_time_lag_ms,omitempty"`
	// Offset of first not read message by consumer from this partition.
	// read_offset can be bigger that committed_offset - consumer could read some messages but not yet commit them.
	ReadOffset uint64 `protobuf:"varint,8,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Consumer lag in time between read and last messages in partition.
	ReadTimeLagMs uint64 `protobuf:"varint,9,opt,name=read_time_lag_ms,json=readTimeLagMs,proto3" json:"read_time_lag_ms,omitempty"`
	// Session identifier that locked and reading this partition right now.
	SessionId string `protobuf:"bytes,10,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Ip if node that created reading this session.
	ClientNode string `protobuf:"bytes,11,opt,name=client_node,json=clientNode,proto3" json:"client_node,omitempty"`
	// Host name of proxy node that processing this reading session.
	ProxyNode string `protobuf:"bytes,12,opt,name=proxy_node,json=proxyNode,proto3" json:"proxy_node,omitempty"`
	// Host name of node where partition leader is running.
	TabletNode string `protobuf:"bytes,13,opt,name=tablet_node,json=tabletNode,proto3" json:"tablet_node,omitempty"`
	// Assign identifier of actual partition assignment.
	AssignId uint64 `protobuf:"varint,14,opt,name=assign_id,json=assignId,proto3" json:"assign_id,omitempty"`
	// Timestamp of assignment.
	AssignTimestampMs uint64 `protobuf:"varint,15,opt,name=assign_timestamp_ms,json=assignTimestampMs,proto3" json:"assign_timestamp_ms,omitempty"`
	// Cookie of last performed read in session.
	LastReadCookie uint64 `protobuf:"varint,16,opt,name=last_read_cookie,json=lastReadCookie,proto3" json:"last_read_cookie,omitempty"`
	// Cookie upto whitch commits done.
	CommittedReadCookie uint64 `protobuf:"varint,17,opt,name=committed_read_cookie,json=committedReadCookie,proto3" json:"committed_read_cookie,omitempty"`
	// Cookie that client wants to commit, but server is waiting for committed_read_cookie + 1.
	OutOfOrderReadCookiesToCommit []uint64 `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral          struct{} `json:"-"`
	XXX_unrecognized              []byte   `json:"-"`
	XXX_sizecache                 int32    `json:"-"`
}

Message containing information about concrete topic's partition reading.

func (*ReadInfoResult_TopicInfo_PartitionInfo) Descriptor 

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

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetAssignId 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetAssignId() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetAssignTimestampMs 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetAssignTimestampMs() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetClientNode 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetClientNode() string

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetCommitOffset 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetCommitOffset() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetCommitTimeLagMs 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetCommitTimeLagMs() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetCommittedReadCookie 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetCommittedReadCookie() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetEndOffset 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetEndOffset() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetIssues 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetIssues() []*Ydb_Issue.IssueMessage

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetLastReadCookie 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetLastReadCookie() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetOutOfOrderReadCookiesToCommit 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetOutOfOrderReadCookiesToCommit() []uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetPartition 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetPartition() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetProxyNode 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetProxyNode() string

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetReadOffset 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetReadOffset() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetReadTimeLagMs 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetReadTimeLagMs() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetSessionId 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetSessionId() string

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetStartOffset 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetStartOffset() uint64

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetStatus 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetStatus() Ydb.StatusIds_StatusCode

func (*ReadInfoResult_TopicInfo_PartitionInfo) GetTabletNode 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) GetTabletNode() string

func (*ReadInfoResult_TopicInfo_PartitionInfo) ProtoMessage 

func (*ReadInfoResult_TopicInfo_PartitionInfo) ProtoMessage()

func (*ReadInfoResult_TopicInfo_PartitionInfo) Reset 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) Reset()

func (*ReadInfoResult_TopicInfo_PartitionInfo) String 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) String() string

func (*ReadInfoResult_TopicInfo_PartitionInfo) XXX_DiscardUnknown 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) XXX_DiscardUnknown()

func (*ReadInfoResult_TopicInfo_PartitionInfo) XXX_Marshal 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInfoResult_TopicInfo_PartitionInfo) XXX_Merge 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) XXX_Merge(src proto.Message)

func (*ReadInfoResult_TopicInfo_PartitionInfo) XXX_Size 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) XXX_Size() int

func (*ReadInfoResult_TopicInfo_PartitionInfo) XXX_Unmarshal 

func (m *ReadInfoResult_TopicInfo_PartitionInfo) XXX_Unmarshal(b []byte) error

type ReadParams 

type ReadParams struct {
	// Max messages to give to client in one read request.
	MaxReadMessagesCount uint32 `` /* 126-byte string literal not displayed */
	// Max size in bytes to give to client in one read request.
	MaxReadSize          uint32   `protobuf:"varint,2,opt,name=max_read_size,json=maxReadSize,proto3" json:"max_read_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Single read parameters for server.

func (*ReadParams) Descriptor 

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

func (*ReadParams) GetMaxReadMessagesCount 

func (m *ReadParams) GetMaxReadMessagesCount() uint32

func (*ReadParams) GetMaxReadSize 

func (m *ReadParams) GetMaxReadSize() uint32

func (*ReadParams) ProtoMessage 

func (*ReadParams) ProtoMessage()

func (*ReadParams) Reset 

func (m *ReadParams) Reset()

func (*ReadParams) String 

func (m *ReadParams) String() string

func (*ReadParams) XXX_DiscardUnknown 

func (m *ReadParams) XXX_DiscardUnknown()

func (*ReadParams) XXX_Marshal 

func (m *ReadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadParams) XXX_Merge 

func (m *ReadParams) XXX_Merge(src proto.Message)

func (*ReadParams) XXX_Size 

func (m *ReadParams) XXX_Size() int

func (*ReadParams) XXX_Unmarshal 

func (m *ReadParams) XXX_Unmarshal(b []byte) error

type RemoveReadRuleRequest 

type RemoveReadRuleRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// read rules to remove. Only consumer names
	ConsumerName         string   `protobuf:"bytes,3,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Remove read rules request for existing topic.

func (*RemoveReadRuleRequest) Descriptor 

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

func (*RemoveReadRuleRequest) GetConsumerName 

func (m *RemoveReadRuleRequest) GetConsumerName() string

func (*RemoveReadRuleRequest) GetOperationParams 

func (m *RemoveReadRuleRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*RemoveReadRuleRequest) GetPath 

func (m *RemoveReadRuleRequest) GetPath() string

func (*RemoveReadRuleRequest) ProtoMessage 

func (*RemoveReadRuleRequest) ProtoMessage()

func (*RemoveReadRuleRequest) Reset 

func (m *RemoveReadRuleRequest) Reset()

func (*RemoveReadRuleRequest) SetOperationParams 

func (m *RemoveReadRuleRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*RemoveReadRuleRequest) String 

func (m *RemoveReadRuleRequest) String() string

func (*RemoveReadRuleRequest) XXX_DiscardUnknown 

func (m *RemoveReadRuleRequest) XXX_DiscardUnknown()

func (*RemoveReadRuleRequest) XXX_Marshal 

func (m *RemoveReadRuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveReadRuleRequest) XXX_Merge 

func (m *RemoveReadRuleRequest) XXX_Merge(src proto.Message)

func (*RemoveReadRuleRequest) XXX_Size 

func (m *RemoveReadRuleRequest) XXX_Size() int

func (*RemoveReadRuleRequest) XXX_Unmarshal 

func (m *RemoveReadRuleRequest) XXX_Unmarshal(b []byte) error

type RemoveReadRuleResponse 

type RemoveReadRuleResponse struct {
	// Result of request will be inside operation.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* Remove read rules response for existing topic.

func (*RemoveReadRuleResponse) Descriptor 

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

func (*RemoveReadRuleResponse) GetOperation 

func (m *RemoveReadRuleResponse) GetOperation() *Ydb_Operations.Operation

func (*RemoveReadRuleResponse) ProtoMessage 

func (*RemoveReadRuleResponse) ProtoMessage()

func (*RemoveReadRuleResponse) Reset 

func (m *RemoveReadRuleResponse) Reset()

func (*RemoveReadRuleResponse) String 

func (m *RemoveReadRuleResponse) String() string

func (*RemoveReadRuleResponse) XXX_DiscardUnknown 

func (m *RemoveReadRuleResponse) XXX_DiscardUnknown()

func (*RemoveReadRuleResponse) XXX_Marshal 

func (m *RemoveReadRuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveReadRuleResponse) XXX_Merge 

func (m *RemoveReadRuleResponse) XXX_Merge(src proto.Message)

func (*RemoveReadRuleResponse) XXX_Size 

func (m *RemoveReadRuleResponse) XXX_Size() int

func (*RemoveReadRuleResponse) XXX_Unmarshal 

func (m *RemoveReadRuleResponse) XXX_Unmarshal(b []byte) error

type RemoveReadRuleResult 

type RemoveReadRuleResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Remove read rules result message that will be inside RemoveReadRuleReponse.operation.

func (*RemoveReadRuleResult) Descriptor 

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

func (*RemoveReadRuleResult) ProtoMessage 

func (*RemoveReadRuleResult) ProtoMessage()

func (*RemoveReadRuleResult) Reset 

func (m *RemoveReadRuleResult) Reset()

func (*RemoveReadRuleResult) String 

func (m *RemoveReadRuleResult) String() string

func (*RemoveReadRuleResult) XXX_DiscardUnknown 

func (m *RemoveReadRuleResult) XXX_DiscardUnknown()

func (*RemoveReadRuleResult) XXX_Marshal 

func (m *RemoveReadRuleResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveReadRuleResult) XXX_Merge 

func (m *RemoveReadRuleResult) XXX_Merge(src proto.Message)

func (*RemoveReadRuleResult) XXX_Size 

func (m *RemoveReadRuleResult) XXX_Size() int

func (*RemoveReadRuleResult) XXX_Unmarshal 

func (m *RemoveReadRuleResult) XXX_Unmarshal(b []byte) error

type SessionMetaValue 

type SessionMetaValue struct {
	Value                map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SessionMetaValue) Descriptor 

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

func (*SessionMetaValue) GetValue 

func (m *SessionMetaValue) GetValue() map[string]string

func (*SessionMetaValue) ProtoMessage 

func (*SessionMetaValue) ProtoMessage()

func (*SessionMetaValue) Reset 

func (m *SessionMetaValue) Reset()

func (*SessionMetaValue) String 

func (m *SessionMetaValue) String() string

func (*SessionMetaValue) XXX_DiscardUnknown 

func (m *SessionMetaValue) XXX_DiscardUnknown()

func (*SessionMetaValue) XXX_Marshal 

func (m *SessionMetaValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionMetaValue) XXX_Merge 

func (m *SessionMetaValue) XXX_Merge(src proto.Message)

func (*SessionMetaValue) XXX_Size 

func (m *SessionMetaValue) XXX_Size() int

func (*SessionMetaValue) XXX_Unmarshal 

func (m *SessionMetaValue) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew 

type StreamingReadClientMessageNew struct {
	// Types that are valid to be assigned to ClientMessage:
	//	*StreamingReadClientMessageNew_InitRequest_
	//	*StreamingReadClientMessageNew_ReadRequest_
	//	*StreamingReadClientMessageNew_CreatePartitionStreamResponse_
	//	*StreamingReadClientMessageNew_CommitRequest_
	//	*StreamingReadClientMessageNew_DestroyPartitionStreamResponse_
	//	*StreamingReadClientMessageNew_StopReadRequest_
	//	*StreamingReadClientMessageNew_ResumeReadRequest_
	//	*StreamingReadClientMessageNew_PartitionStreamStatusRequest_
	//	*StreamingReadClientMessageNew_AddTopicRequest_
	//	*StreamingReadClientMessageNew_RemoveTopicRequest_
	ClientMessage isStreamingReadClientMessageNew_ClientMessage `protobuf_oneof:"client_message"`
	// User credentials if update is needed or empty string.
	Token                string   `protobuf:"bytes,20,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Request for read session. Contains one of: 

InitRequest - handshake request.
ReadRequest - request for data.
CommitRequest - request for commit of some read data.
CreatePartitionStreamResponse - signal for server that client is ready to get data from partition.
DestroyPartitionStreamResponse - signal for server that client finished working with partition. Must be sent only after corresponding Release request from server.
StopReadRequest - signal for server that client is not ready to get more data from this partition.
ResumeReadRequest - signal for server that client is ready to get more data from this partition.

func (*StreamingReadClientMessageNew) Descriptor 

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

func (*StreamingReadClientMessageNew) GetAddTopicRequest 

func (m *StreamingReadClientMessageNew) GetAddTopicRequest() *StreamingReadClientMessageNew_AddTopicRequest

func (*StreamingReadClientMessageNew) GetClientMessage 

func (m *StreamingReadClientMessageNew) GetClientMessage() isStreamingReadClientMessageNew_ClientMessage

func (*StreamingReadClientMessageNew) GetCommitRequest 

func (m *StreamingReadClientMessageNew) GetCommitRequest() *StreamingReadClientMessageNew_CommitRequest

func (*StreamingReadClientMessageNew) GetCreatePartitionStreamResponse 

func (m *StreamingReadClientMessageNew) GetCreatePartitionStreamResponse() *StreamingReadClientMessageNew_CreatePartitionStreamResponse

func (*StreamingReadClientMessageNew) GetDestroyPartitionStreamResponse 

func (m *StreamingReadClientMessageNew) GetDestroyPartitionStreamResponse() *StreamingReadClientMessageNew_DestroyPartitionStreamResponse

func (*StreamingReadClientMessageNew) GetInitRequest 

func (m *StreamingReadClientMessageNew) GetInitRequest() *StreamingReadClientMessageNew_InitRequest

func (*StreamingReadClientMessageNew) GetPartitionStreamStatusRequest 

func (m *StreamingReadClientMessageNew) GetPartitionStreamStatusRequest() *StreamingReadClientMessageNew_PartitionStreamStatusRequest

func (*StreamingReadClientMessageNew) GetReadRequest 

func (m *StreamingReadClientMessageNew) GetReadRequest() *StreamingReadClientMessageNew_ReadRequest

func (*StreamingReadClientMessageNew) GetRemoveTopicRequest 

func (m *StreamingReadClientMessageNew) GetRemoveTopicRequest() *StreamingReadClientMessageNew_RemoveTopicRequest

func (*StreamingReadClientMessageNew) GetResumeReadRequest 

func (m *StreamingReadClientMessageNew) GetResumeReadRequest() *StreamingReadClientMessageNew_ResumeReadRequest

func (*StreamingReadClientMessageNew) GetStopReadRequest 

func (m *StreamingReadClientMessageNew) GetStopReadRequest() *StreamingReadClientMessageNew_StopReadRequest

func (*StreamingReadClientMessageNew) GetToken 

func (m *StreamingReadClientMessageNew) GetToken() string

func (*StreamingReadClientMessageNew) ProtoMessage 

func (*StreamingReadClientMessageNew) ProtoMessage()

func (*StreamingReadClientMessageNew) Reset 

func (m *StreamingReadClientMessageNew) Reset()

func (*StreamingReadClientMessageNew) String 

func (m *StreamingReadClientMessageNew) String() string

func (*StreamingReadClientMessageNew) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew) XXX_Marshal 

func (m *StreamingReadClientMessageNew) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew) XXX_Merge 

func (m *StreamingReadClientMessageNew) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew) XXX_OneofWrappers 

func (*StreamingReadClientMessageNew) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamingReadClientMessageNew) XXX_Size 

func (m *StreamingReadClientMessageNew) XXX_Size() int

func (*StreamingReadClientMessageNew) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_AddTopicRequest 

type StreamingReadClientMessageNew_AddTopicRequest struct {
	TopicReadSettings    *StreamingReadClientMessageNew_TopicReadSettings `protobuf:"bytes,1,opt,name=topic_read_settings,json=topicReadSettings,proto3" json:"topic_read_settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

Add topic to current read session

func (*StreamingReadClientMessageNew_AddTopicRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_AddTopicRequest) GetTopicReadSettings 

func (m *StreamingReadClientMessageNew_AddTopicRequest) GetTopicReadSettings() *StreamingReadClientMessageNew_TopicReadSettings

func (*StreamingReadClientMessageNew_AddTopicRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_AddTopicRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_AddTopicRequest) Reset 

func (m *StreamingReadClientMessageNew_AddTopicRequest) Reset()

func (*StreamingReadClientMessageNew_AddTopicRequest) String 

func (m *StreamingReadClientMessageNew_AddTopicRequest) String() string

func (*StreamingReadClientMessageNew_AddTopicRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_AddTopicRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_AddTopicRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_AddTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_AddTopicRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_AddTopicRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_AddTopicRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_AddTopicRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_AddTopicRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_AddTopicRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_AddTopicRequest_ 

type StreamingReadClientMessageNew_AddTopicRequest_ struct {
	AddTopicRequest *StreamingReadClientMessageNew_AddTopicRequest `protobuf:"bytes,9,opt,name=add_topic_request,json=addTopicRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_CommitRequest 

type StreamingReadClientMessageNew_CommitRequest struct {
	// Partition offsets that indicates processed data.
	Commits              []*StreamingReadClientMessageNew_PartitionCommit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

Signal for server that client processed some read data.

func (*StreamingReadClientMessageNew_CommitRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_CommitRequest) GetCommits 

func (m *StreamingReadClientMessageNew_CommitRequest) GetCommits() []*StreamingReadClientMessageNew_PartitionCommit

func (*StreamingReadClientMessageNew_CommitRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_CommitRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_CommitRequest) Reset 

func (m *StreamingReadClientMessageNew_CommitRequest) Reset()

func (*StreamingReadClientMessageNew_CommitRequest) String 

func (m *StreamingReadClientMessageNew_CommitRequest) String() string

func (*StreamingReadClientMessageNew_CommitRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_CommitRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_CommitRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_CommitRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_CommitRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_CommitRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_CommitRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_CommitRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_CommitRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_CommitRequest_ 

type StreamingReadClientMessageNew_CommitRequest_ struct {
	CommitRequest *StreamingReadClientMessageNew_CommitRequest `protobuf:"bytes,4,opt,name=commit_request,json=commitRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_CreatePartitionStreamResponse 

type StreamingReadClientMessageNew_CreatePartitionStreamResponse struct {
	// Partition stream identifier of partition to start read.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Start reading from partition offset that is not less than read_offset.
	// Init.max_time_lag_ms and Init.read_timestamp_ms could lead to skip of more messages.
	// The same with actual committed offset. Regardless of set read_offset server will return data from maximal offset from read_offset, actual committed offset
	// and offsets calculated from Init.max_time_lag_ms and Init.read_timestamp_ms.
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// All messages with offset less than commit_offset are processed by client. Server will commit this position if this is not done yet.
	CommitOffset int64 `protobuf:"varint,3,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	// This option will enable sanity check on server for read_offset. Server will verify that read_offset is no less that actual committed offset.
	// If verification will fail then server will kill this read session and client will find out error in reading logic.
	// If client is not setting read_offset, sanity check will fail so do not set verify_read_offset if you not setting correct read_offset.
	VerifyReadOffset     bool     `protobuf:"varint,4,opt,name=verify_read_offset,json=verifyReadOffset,proto3" json:"verify_read_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal for server that cient is ready to recive data for partition.

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) Descriptor 

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

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetCommitOffset 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetCommitOffset() int64

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetPartitionStreamId 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetPartitionStreamId() int64

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetReadOffset 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetReadOffset() int64

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetVerifyReadOffset 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) GetVerifyReadOffset() bool

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) ProtoMessage 

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) ProtoMessage()

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) Reset 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) Reset()

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) String 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) String() string

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Marshal 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Merge 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Size 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Size() int

func (*StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_CreatePartitionStreamResponse) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_CreatePartitionStreamResponse_ 

type StreamingReadClientMessageNew_CreatePartitionStreamResponse_ struct {
	CreatePartitionStreamResponse *StreamingReadClientMessageNew_CreatePartitionStreamResponse `protobuf:"bytes,3,opt,name=create_partition_stream_response,json=createPartitionStreamResponse,proto3,oneof"`
}

type StreamingReadClientMessageNew_DestroyPartitionStreamResponse 

type StreamingReadClientMessageNew_DestroyPartitionStreamResponse struct {
	// Partition stream identifier of partition partition stream that is released by client.
	PartitionStreamId    int64    `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal for server that client finished working with this partition. Must be sent only after corresponding Release request from server. Server will give this partition to other read session only after Released signal.

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) Descriptor 

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

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) GetPartitionStreamId 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) GetPartitionStreamId() int64

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) ProtoMessage 

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) ProtoMessage()

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) Reset 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) Reset()

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) String 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) String() string

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Marshal 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Merge 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Size 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Size() int

func (*StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_DestroyPartitionStreamResponse) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_DestroyPartitionStreamResponse_ 

type StreamingReadClientMessageNew_DestroyPartitionStreamResponse_ struct {
	DestroyPartitionStreamResponse *StreamingReadClientMessageNew_DestroyPartitionStreamResponse `protobuf:"bytes,5,opt,name=destroy_partition_stream_response,json=destroyPartitionStreamResponse,proto3,oneof"`
}

type StreamingReadClientMessageNew_InitRequest 

type StreamingReadClientMessageNew_InitRequest struct {
	// Message that describes topic to read.
	// Topics that will be read by this session.
	TopicsReadSettings []*StreamingReadClientMessageNew_TopicReadSettings `protobuf:"bytes,1,rep,name=topics_read_settings,json=topicsReadSettings,proto3" json:"topics_read_settings,omitempty"`
	// Flag that indicates reading only of original topics in cluster or all including mirrored.
	ReadOnlyOriginal bool `protobuf:"varint,2,opt,name=read_only_original,json=readOnlyOriginal,proto3" json:"read_only_original,omitempty"`
	// Path of consumer that is used for reading by this session.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Skip all messages that has write timestamp smaller than now - max_time_lag_ms.
	MaxLagDurationMs int64 `protobuf:"varint,4,opt,name=max_lag_duration_ms,json=maxLagDurationMs,proto3" json:"max_lag_duration_ms,omitempty"`
	// Read data only after this timestamp from all topics.
	StartFromWrittenAtMs int64 `` /* 128-byte string literal not displayed */
	// Maximum block format version supported by the client. Server will asses this parameter and return actual data blocks version in
	// StreamingReadServerMessage.InitResponse.block_format_version_by_topic (and StreamingReadServerMessage.AddTopicResponse.block_format_version)
	// or error if client will not be able to read data.
	MaxSupportedBlockFormatVersion int64 `` /* 158-byte string literal not displayed */
	// Maximal size of client cache for message_group_id, ip and meta, per partition.
	// There is separate caches for each partition partition streams.
	// There is separate caches for message group identifiers, ip and meta inside one partition partition stream.
	MaxMetaCacheSize int64 `protobuf:"varint,10,opt,name=max_meta_cache_size,json=maxMetaCacheSize,proto3" json:"max_meta_cache_size,omitempty"`
	// Session identifier for retries. Must be the same as session_id from Inited server response. If this is first connect, not retry - do not use this field.
	SessionId string `protobuf:"bytes,100,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// 0 for first init message and incremental value for connect retries.
	ConnectionAttempt int64 `protobuf:"varint,101,opt,name=connection_attempt,json=connectionAttempt,proto3" json:"connection_attempt,omitempty"`
	// Formed state for retries. If not retry - do not use this field.
	State                *StreamingReadClientMessageNew_InitRequest_State `protobuf:"bytes,102,opt,name=state,proto3" json:"state,omitempty"`
	IdleTimeoutMs        int64                                            `protobuf:"varint,200,opt,name=idle_timeout_ms,json=idleTimeoutMs,proto3" json:"idle_timeout_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

Handshake request.

func (*StreamingReadClientMessageNew_InitRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_InitRequest) GetConnectionAttempt 

func (m *StreamingReadClientMessageNew_InitRequest) GetConnectionAttempt() int64

func (*StreamingReadClientMessageNew_InitRequest) GetConsumer 

func (m *StreamingReadClientMessageNew_InitRequest) GetConsumer() string

func (*StreamingReadClientMessageNew_InitRequest) GetIdleTimeoutMs 

func (m *StreamingReadClientMessageNew_InitRequest) GetIdleTimeoutMs() int64

func (*StreamingReadClientMessageNew_InitRequest) GetMaxLagDurationMs 

func (m *StreamingReadClientMessageNew_InitRequest) GetMaxLagDurationMs() int64

func (*StreamingReadClientMessageNew_InitRequest) GetMaxMetaCacheSize 

func (m *StreamingReadClientMessageNew_InitRequest) GetMaxMetaCacheSize() int64

func (*StreamingReadClientMessageNew_InitRequest) GetMaxSupportedBlockFormatVersion 

func (m *StreamingReadClientMessageNew_InitRequest) GetMaxSupportedBlockFormatVersion() int64

func (*StreamingReadClientMessageNew_InitRequest) GetReadOnlyOriginal 

func (m *StreamingReadClientMessageNew_InitRequest) GetReadOnlyOriginal() bool

func (*StreamingReadClientMessageNew_InitRequest) GetSessionId 

func (m *StreamingReadClientMessageNew_InitRequest) GetSessionId() string

func (*StreamingReadClientMessageNew_InitRequest) GetStartFromWrittenAtMs 

func (m *StreamingReadClientMessageNew_InitRequest) GetStartFromWrittenAtMs() int64

func (*StreamingReadClientMessageNew_InitRequest) GetState 

func (m *StreamingReadClientMessageNew_InitRequest) GetState() *StreamingReadClientMessageNew_InitRequest_State

func (*StreamingReadClientMessageNew_InitRequest) GetTopicsReadSettings 

func (m *StreamingReadClientMessageNew_InitRequest) GetTopicsReadSettings() []*StreamingReadClientMessageNew_TopicReadSettings

func (*StreamingReadClientMessageNew_InitRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_InitRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_InitRequest) Reset 

func (m *StreamingReadClientMessageNew_InitRequest) Reset()

func (*StreamingReadClientMessageNew_InitRequest) String 

func (m *StreamingReadClientMessageNew_InitRequest) String() string

func (*StreamingReadClientMessageNew_InitRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_InitRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_InitRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_InitRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_InitRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_InitRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_InitRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_InitRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_InitRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_InitRequest_ 

type StreamingReadClientMessageNew_InitRequest_ struct {
	InitRequest *StreamingReadClientMessageNew_InitRequest `protobuf:"bytes,1,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_InitRequest_State 

type StreamingReadClientMessageNew_InitRequest_State struct {
	PartitionStreamsStates []*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                                                                `json:"-"`
	XXX_unrecognized       []byte                                                                  `json:"-"`
	XXX_sizecache          int32                                                                   `json:"-"`
}

State of client read session. Could be provided to server for retries.

func (*StreamingReadClientMessageNew_InitRequest_State) Descriptor 

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

func (*StreamingReadClientMessageNew_InitRequest_State) GetPartitionStreamsStates 

func (m *StreamingReadClientMessageNew_InitRequest_State) GetPartitionStreamsStates() []*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState

func (*StreamingReadClientMessageNew_InitRequest_State) ProtoMessage 

func (*StreamingReadClientMessageNew_InitRequest_State) ProtoMessage()

func (*StreamingReadClientMessageNew_InitRequest_State) Reset 

func (m *StreamingReadClientMessageNew_InitRequest_State) Reset()

func (*StreamingReadClientMessageNew_InitRequest_State) String 

func (m *StreamingReadClientMessageNew_InitRequest_State) String() string

func (*StreamingReadClientMessageNew_InitRequest_State) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_InitRequest_State) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_InitRequest_State) XXX_Marshal 

func (m *StreamingReadClientMessageNew_InitRequest_State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_InitRequest_State) XXX_Merge 

func (m *StreamingReadClientMessageNew_InitRequest_State) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_InitRequest_State) XXX_Size 

func (m *StreamingReadClientMessageNew_InitRequest_State) XXX_Size() int

func (*StreamingReadClientMessageNew_InitRequest_State) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_InitRequest_State) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState 

type StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState struct {
	// Partition partition stream.
	PartitionStream *PartitionStream `protobuf:"bytes,1,opt,name=partition_stream,json=partitionStream,proto3" json:"partition_stream,omitempty"`
	// Current read offset if has one. Actual for states DESTROYING, READING and STOPPED.
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Ranges of committed by client offsets.
	OffsetRanges []*OffsetsRange `protobuf:"bytes,3,rep,name=offset_ranges,json=offsetRanges,proto3" json:"offset_ranges,omitempty"`
	// Status of partition stream.
	Status               StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                                    `json:"-"`
	XXX_unrecognized     []byte                                                                      `json:"-"`
	XXX_sizecache        int32                                                                       `json:"-"`
}

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) Descriptor 

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

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetOffsetRanges 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetOffsetRanges() []*OffsetsRange

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetPartitionStream 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetPartitionStream() *PartitionStream

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetReadOffset 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetReadOffset() int64

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetStatus 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) GetStatus() StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) ProtoMessage 

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) ProtoMessage()

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) Reset 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) Reset()

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) String 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) String() string

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Marshal 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Merge 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Size 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Size() int

func (*StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status 

type StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status int32
const (
	// Not used state.
	StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_STATUS_UNSPECIFIED StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status = 0
	// Client seen Create message but not yet responded to server with Created message.
	StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_CREATING StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status = 1
	// Client seen Destroy message but not yet responded with Released message.
	StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_DESTROYING StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status = 2
	// Client sent Created or ResumeReadRequest message to server for this partition stream.
	StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_READING StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status = 3
	// Client sent StopReadRequest for this partition stream.
	StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_STOPPED StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status = 4
)

func (StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status) EnumDescriptor 

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

func (StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status) String 

func (x StreamingReadClientMessageNew_InitRequest_State_PartitionStreamState_Status) String() string

type StreamingReadClientMessageNew_PartitionCommit 

type StreamingReadClientMessageNew_PartitionCommit struct {
	// Identifier of partition stream with data to commit.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Processed ranges.
	Offsets              []*OffsetsRange `protobuf:"bytes,2,rep,name=offsets,proto3" json:"offsets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

* Message that is used for describing commit.

func (*StreamingReadClientMessageNew_PartitionCommit) Descriptor 

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

func (*StreamingReadClientMessageNew_PartitionCommit) GetOffsets 

func (m *StreamingReadClientMessageNew_PartitionCommit) GetOffsets() []*OffsetsRange

func (*StreamingReadClientMessageNew_PartitionCommit) GetPartitionStreamId 

func (m *StreamingReadClientMessageNew_PartitionCommit) GetPartitionStreamId() int64

func (*StreamingReadClientMessageNew_PartitionCommit) ProtoMessage 

func (*StreamingReadClientMessageNew_PartitionCommit) ProtoMessage()

func (*StreamingReadClientMessageNew_PartitionCommit) Reset 

func (m *StreamingReadClientMessageNew_PartitionCommit) Reset()

func (*StreamingReadClientMessageNew_PartitionCommit) String 

func (m *StreamingReadClientMessageNew_PartitionCommit) String() string

func (*StreamingReadClientMessageNew_PartitionCommit) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_PartitionCommit) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_PartitionCommit) XXX_Marshal 

func (m *StreamingReadClientMessageNew_PartitionCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_PartitionCommit) XXX_Merge 

func (m *StreamingReadClientMessageNew_PartitionCommit) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_PartitionCommit) XXX_Size 

func (m *StreamingReadClientMessageNew_PartitionCommit) XXX_Size() int

func (*StreamingReadClientMessageNew_PartitionCommit) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_PartitionCommit) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_PartitionStreamStatusRequest 

type StreamingReadClientMessageNew_PartitionStreamStatusRequest struct {
	PartitionStreamId    int64    `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) GetPartitionStreamId 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) GetPartitionStreamId() int64

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) Reset 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) Reset()

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) String 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) String() string

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_PartitionStreamStatusRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_PartitionStreamStatusRequest_ 

type StreamingReadClientMessageNew_PartitionStreamStatusRequest_ struct {
	PartitionStreamStatusRequest *StreamingReadClientMessageNew_PartitionStreamStatusRequest `protobuf:"bytes,8,opt,name=partition_stream_status_request,json=partitionStreamStatusRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_ReadRequest 

type StreamingReadClientMessageNew_ReadRequest struct {
	// Client acquired this amount of free bytes more for buffer. Server can send more data at most of this uncompressed size.
	// Subsequent messages with 5 and 10 request_uncompressed_size are treated by server that it can send messages for at most 15 bytes.
	RequestUncompressedSize int64    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

Message that represents client readiness for receiving more data.

func (*StreamingReadClientMessageNew_ReadRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_ReadRequest) GetRequestUncompressedSize 

func (m *StreamingReadClientMessageNew_ReadRequest) GetRequestUncompressedSize() int64

func (*StreamingReadClientMessageNew_ReadRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_ReadRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_ReadRequest) Reset 

func (m *StreamingReadClientMessageNew_ReadRequest) Reset()

func (*StreamingReadClientMessageNew_ReadRequest) String 

func (m *StreamingReadClientMessageNew_ReadRequest) String() string

func (*StreamingReadClientMessageNew_ReadRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_ReadRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_ReadRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_ReadRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_ReadRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_ReadRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_ReadRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_ReadRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_ReadRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_ReadRequest_ 

type StreamingReadClientMessageNew_ReadRequest_ struct {
	ReadRequest *StreamingReadClientMessageNew_ReadRequest `protobuf:"bytes,2,opt,name=read_request,json=readRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_RemoveTopicRequest 

type StreamingReadClientMessageNew_RemoveTopicRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Remove topic from current read session

func (*StreamingReadClientMessageNew_RemoveTopicRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_RemoveTopicRequest) GetTopic 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) GetTopic() string

func (*StreamingReadClientMessageNew_RemoveTopicRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_RemoveTopicRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_RemoveTopicRequest) Reset 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) Reset()

func (*StreamingReadClientMessageNew_RemoveTopicRequest) String 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) String() string

func (*StreamingReadClientMessageNew_RemoveTopicRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_RemoveTopicRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_RemoveTopicRequest_ 

type StreamingReadClientMessageNew_RemoveTopicRequest_ struct {
	RemoveTopicRequest *StreamingReadClientMessageNew_RemoveTopicRequest `protobuf:"bytes,10,opt,name=remove_topic_request,json=removeTopicRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_ResumeReadRequest 

type StreamingReadClientMessageNew_ResumeReadRequest struct {
	PartitionStreamIds []int64 `protobuf:"varint,1,rep,packed,name=partition_stream_ids,json=partitionStreamIds,proto3" json:"partition_stream_ids,omitempty"`
	// Offset to start reading - may be smaller than known one in case of dropping of read-ahead in client lib.
	ReadOffsets []int64 `protobuf:"varint,2,rep,packed,name=read_offsets,json=readOffsets,proto3" json:"read_offsets,omitempty"`
	// Cookie for matching data from PartitionStream after resuming. Must be greater than zero.
	ResumeCookies        []int64  `protobuf:"varint,3,rep,packed,name=resume_cookies,json=resumeCookies,proto3" json:"resume_cookies,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal for server that client is ready to receive more data from this partition.

func (*StreamingReadClientMessageNew_ResumeReadRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_ResumeReadRequest) GetPartitionStreamIds 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) GetPartitionStreamIds() []int64

func (*StreamingReadClientMessageNew_ResumeReadRequest) GetReadOffsets 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) GetReadOffsets() []int64

func (*StreamingReadClientMessageNew_ResumeReadRequest) GetResumeCookies 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) GetResumeCookies() []int64

func (*StreamingReadClientMessageNew_ResumeReadRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_ResumeReadRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_ResumeReadRequest) Reset 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) Reset()

func (*StreamingReadClientMessageNew_ResumeReadRequest) String 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) String() string

func (*StreamingReadClientMessageNew_ResumeReadRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_ResumeReadRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_ResumeReadRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_ResumeReadRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_ResumeReadRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_ResumeReadRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_ResumeReadRequest_ 

type StreamingReadClientMessageNew_ResumeReadRequest_ struct {
	ResumeReadRequest *StreamingReadClientMessageNew_ResumeReadRequest `protobuf:"bytes,7,opt,name=resume_read_request,json=resumeReadRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_StopReadRequest 

type StreamingReadClientMessageNew_StopReadRequest struct {
	PartitionStreamIds   []int64  `protobuf:"varint,1,rep,packed,name=partition_stream_ids,json=partitionStreamIds,proto3" json:"partition_stream_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Signal for server that client is not ready to recieve more data from this partition.

func (*StreamingReadClientMessageNew_StopReadRequest) Descriptor 

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

func (*StreamingReadClientMessageNew_StopReadRequest) GetPartitionStreamIds 

func (m *StreamingReadClientMessageNew_StopReadRequest) GetPartitionStreamIds() []int64

func (*StreamingReadClientMessageNew_StopReadRequest) ProtoMessage 

func (*StreamingReadClientMessageNew_StopReadRequest) ProtoMessage()

func (*StreamingReadClientMessageNew_StopReadRequest) Reset 

func (m *StreamingReadClientMessageNew_StopReadRequest) Reset()

func (*StreamingReadClientMessageNew_StopReadRequest) String 

func (m *StreamingReadClientMessageNew_StopReadRequest) String() string

func (*StreamingReadClientMessageNew_StopReadRequest) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_StopReadRequest) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_StopReadRequest) XXX_Marshal 

func (m *StreamingReadClientMessageNew_StopReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_StopReadRequest) XXX_Merge 

func (m *StreamingReadClientMessageNew_StopReadRequest) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_StopReadRequest) XXX_Size 

func (m *StreamingReadClientMessageNew_StopReadRequest) XXX_Size() int

func (*StreamingReadClientMessageNew_StopReadRequest) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_StopReadRequest) XXX_Unmarshal(b []byte) error

type StreamingReadClientMessageNew_StopReadRequest_ 

type StreamingReadClientMessageNew_StopReadRequest_ struct {
	StopReadRequest *StreamingReadClientMessageNew_StopReadRequest `protobuf:"bytes,6,opt,name=stop_read_request,json=stopReadRequest,proto3,oneof"`
}

type StreamingReadClientMessageNew_TopicReadSettings 

type StreamingReadClientMessageNew_TopicReadSettings struct {
	// Topic path.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Partition groups that will be read by this session.
	// If list is empty - then session will read all partition groups.
	PartitionGroupIds []int64 `protobuf:"varint,2,rep,packed,name=partition_group_ids,json=partitionGroupIds,proto3" json:"partition_group_ids,omitempty"`
	// Read data only after this timestamp from this topic.
	StartFromWrittenAtMs int64    `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadClientMessageNew_TopicReadSettings) Descriptor 

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

func (*StreamingReadClientMessageNew_TopicReadSettings) GetPartitionGroupIds 

func (m *StreamingReadClientMessageNew_TopicReadSettings) GetPartitionGroupIds() []int64

func (*StreamingReadClientMessageNew_TopicReadSettings) GetStartFromWrittenAtMs 

func (m *StreamingReadClientMessageNew_TopicReadSettings) GetStartFromWrittenAtMs() int64

func (*StreamingReadClientMessageNew_TopicReadSettings) GetTopic 

func (m *StreamingReadClientMessageNew_TopicReadSettings) GetTopic() string

func (*StreamingReadClientMessageNew_TopicReadSettings) ProtoMessage 

func (*StreamingReadClientMessageNew_TopicReadSettings) ProtoMessage()

func (*StreamingReadClientMessageNew_TopicReadSettings) Reset 

func (m *StreamingReadClientMessageNew_TopicReadSettings) Reset()

func (*StreamingReadClientMessageNew_TopicReadSettings) String 

func (m *StreamingReadClientMessageNew_TopicReadSettings) String() string

func (*StreamingReadClientMessageNew_TopicReadSettings) XXX_DiscardUnknown 

func (m *StreamingReadClientMessageNew_TopicReadSettings) XXX_DiscardUnknown()

func (*StreamingReadClientMessageNew_TopicReadSettings) XXX_Marshal 

func (m *StreamingReadClientMessageNew_TopicReadSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadClientMessageNew_TopicReadSettings) XXX_Merge 

func (m *StreamingReadClientMessageNew_TopicReadSettings) XXX_Merge(src proto.Message)

func (*StreamingReadClientMessageNew_TopicReadSettings) XXX_Size 

func (m *StreamingReadClientMessageNew_TopicReadSettings) XXX_Size() int

func (*StreamingReadClientMessageNew_TopicReadSettings) XXX_Unmarshal 

func (m *StreamingReadClientMessageNew_TopicReadSettings) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew 

type StreamingReadServerMessageNew struct {
	// Types that are valid to be assigned to ServerMessage:
	//	*StreamingReadServerMessageNew_InitResponse_
	//	*StreamingReadServerMessageNew_BatchReadResponse_
	//	*StreamingReadServerMessageNew_CreatePartitionStreamRequest_
	//	*StreamingReadServerMessageNew_DestroyPartitionStreamRequest_
	//	*StreamingReadServerMessageNew_CommitResponse_
	//	*StreamingReadServerMessageNew_PartitionStreamStatusResponse_
	//	*StreamingReadServerMessageNew_StopReadResponse_
	//	*StreamingReadServerMessageNew_ResumeReadResponse_
	//	*StreamingReadServerMessageNew_AddTopicResponse_
	//	*StreamingReadServerMessageNew_RemoveTopicResponse_
	ServerMessage        isStreamingReadServerMessageNew_ServerMessage `protobuf_oneof:"server_message"`
	Status               Ydb.StatusIds_StatusCode                      `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues               []*Ydb_Issue.IssueMessage                     `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

* Response for read session. Contains one of : 

InitResponse - handshake response from server.
BatchReadResponse - portion of data.
CommitResponse - acknowledgment for commit.
CreatePartitionStreamRequest - command from server to create a partition partition stream.
DestroyPartitionStreamRequest - command from server to destroy a partition partition stream.

func (*StreamingReadServerMessageNew) Descriptor 

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

func (*StreamingReadServerMessageNew) GetAddTopicResponse 

func (m *StreamingReadServerMessageNew) GetAddTopicResponse() *StreamingReadServerMessageNew_AddTopicResponse

func (*StreamingReadServerMessageNew) GetBatchReadResponse 

func (m *StreamingReadServerMessageNew) GetBatchReadResponse() *StreamingReadServerMessageNew_BatchReadResponse

func (*StreamingReadServerMessageNew) GetCommitResponse 

func (m *StreamingReadServerMessageNew) GetCommitResponse() *StreamingReadServerMessageNew_CommitResponse

func (*StreamingReadServerMessageNew) GetCreatePartitionStreamRequest 

func (m *StreamingReadServerMessageNew) GetCreatePartitionStreamRequest() *StreamingReadServerMessageNew_CreatePartitionStreamRequest

func (*StreamingReadServerMessageNew) GetDestroyPartitionStreamRequest 

func (m *StreamingReadServerMessageNew) GetDestroyPartitionStreamRequest() *StreamingReadServerMessageNew_DestroyPartitionStreamRequest

func (*StreamingReadServerMessageNew) GetInitResponse 

func (m *StreamingReadServerMessageNew) GetInitResponse() *StreamingReadServerMessageNew_InitResponse

func (*StreamingReadServerMessageNew) GetIssues 

func (m *StreamingReadServerMessageNew) GetIssues() []*Ydb_Issue.IssueMessage

func (*StreamingReadServerMessageNew) GetPartitionStreamStatusResponse 

func (m *StreamingReadServerMessageNew) GetPartitionStreamStatusResponse() *StreamingReadServerMessageNew_PartitionStreamStatusResponse

func (*StreamingReadServerMessageNew) GetRemoveTopicResponse 

func (m *StreamingReadServerMessageNew) GetRemoveTopicResponse() *StreamingReadServerMessageNew_RemoveTopicResponse

func (*StreamingReadServerMessageNew) GetResumeReadResponse 

func (m *StreamingReadServerMessageNew) GetResumeReadResponse() *StreamingReadServerMessageNew_ResumeReadResponse

func (*StreamingReadServerMessageNew) GetServerMessage 

func (m *StreamingReadServerMessageNew) GetServerMessage() isStreamingReadServerMessageNew_ServerMessage

func (*StreamingReadServerMessageNew) GetStatus 

func (m *StreamingReadServerMessageNew) GetStatus() Ydb.StatusIds_StatusCode

func (*StreamingReadServerMessageNew) GetStopReadResponse 

func (m *StreamingReadServerMessageNew) GetStopReadResponse() *StreamingReadServerMessageNew_StopReadResponse

func (*StreamingReadServerMessageNew) ProtoMessage 

func (*StreamingReadServerMessageNew) ProtoMessage()

func (*StreamingReadServerMessageNew) Reset 

func (m *StreamingReadServerMessageNew) Reset()

func (*StreamingReadServerMessageNew) String 

func (m *StreamingReadServerMessageNew) String() string

func (*StreamingReadServerMessageNew) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew) XXX_Marshal 

func (m *StreamingReadServerMessageNew) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew) XXX_Merge 

func (m *StreamingReadServerMessageNew) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew) XXX_OneofWrappers 

func (*StreamingReadServerMessageNew) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamingReadServerMessageNew) XXX_Size 

func (m *StreamingReadServerMessageNew) XXX_Size() int

func (*StreamingReadServerMessageNew) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_AddTopicResponse 

type StreamingReadServerMessageNew_AddTopicResponse struct {
	// Block format version of data client will receive from the topic.
	BlockFormatVersion   int64    `protobuf:"varint,1,opt,name=block_format_version,json=blockFormatVersion,proto3" json:"block_format_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadServerMessageNew_AddTopicResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_AddTopicResponse) GetBlockFormatVersion 

func (m *StreamingReadServerMessageNew_AddTopicResponse) GetBlockFormatVersion() int64

func (*StreamingReadServerMessageNew_AddTopicResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_AddTopicResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_AddTopicResponse) Reset 

func (m *StreamingReadServerMessageNew_AddTopicResponse) Reset()

func (*StreamingReadServerMessageNew_AddTopicResponse) String 

func (m *StreamingReadServerMessageNew_AddTopicResponse) String() string

func (*StreamingReadServerMessageNew_AddTopicResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_AddTopicResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_AddTopicResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_AddTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_AddTopicResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_AddTopicResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_AddTopicResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_AddTopicResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_AddTopicResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_AddTopicResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_AddTopicResponse_ 

type StreamingReadServerMessageNew_AddTopicResponse_ struct {
	AddTopicResponse *StreamingReadServerMessageNew_AddTopicResponse `protobuf:"bytes,11,opt,name=add_topic_response,json=addTopicResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_BatchReadResponse 

type StreamingReadServerMessageNew_BatchReadResponse struct {
	SkipRange []*StreamingReadServerMessageNew_BatchReadResponse_SkipRange `protobuf:"bytes,1,rep,name=skip_range,json=skipRange,proto3" json:"skip_range,omitempty"`
	// Per-partition data.
	Partitions           []*StreamingReadServerMessageNew_BatchReadResponse_PartitionData `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                                         `json:"-"`
	XXX_unrecognized     []byte                                                           `json:"-"`
	XXX_sizecache        int32                                                            `json:"-"`
}

Readed data.

func (*StreamingReadServerMessageNew_BatchReadResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_BatchReadResponse) GetPartitions 

func (m *StreamingReadServerMessageNew_BatchReadResponse) GetPartitions() []*StreamingReadServerMessageNew_BatchReadResponse_PartitionData

func (*StreamingReadServerMessageNew_BatchReadResponse) GetSkipRange 

func (m *StreamingReadServerMessageNew_BatchReadResponse) GetSkipRange() []*StreamingReadServerMessageNew_BatchReadResponse_SkipRange

func (*StreamingReadServerMessageNew_BatchReadResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_BatchReadResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_BatchReadResponse) Reset 

func (m *StreamingReadServerMessageNew_BatchReadResponse) Reset()

func (*StreamingReadServerMessageNew_BatchReadResponse) String 

func (m *StreamingReadServerMessageNew_BatchReadResponse) String() string

func (*StreamingReadServerMessageNew_BatchReadResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_BatchReadResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_BatchReadResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_BatchReadResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_BatchReadResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_BatchReadResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_BatchReadResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_BatchReadResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_BatchReadResponse_ 

type StreamingReadServerMessageNew_BatchReadResponse_ struct {
	BatchReadResponse *StreamingReadServerMessageNew_BatchReadResponse `protobuf:"bytes,4,opt,name=batch_read_response,json=batchReadResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_BatchReadResponse_PartitionData 

type StreamingReadServerMessageNew_BatchReadResponse_PartitionData struct {
	// Data inside this message is from partition stream with this identifier.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Offsets in partition that assigned for messages.
	// Unique value for clientside deduplication - (topic, cluster, partition_id, offset).
	Offsets []int64 `protobuf:"varint,2,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	// Sequence numbers that provided with messages on write from client.
	// Same size as offsets.
	// Unique value for clientside deduplication - (topic, cluster, message_group_id, sequence_number).
	SequenceNumbers []int64 `protobuf:"varint,3,rep,packed,name=sequence_numbers,json=sequenceNumbers,proto3" json:"sequence_numbers,omitempty"`
	// Timestamps of creation of messages provided on write from client.
	// Same size as offsets.
	CreatedAtMs []int64 `protobuf:"varint,4,rep,packed,name=created_at_ms,json=createdAtMs,proto3" json:"created_at_ms,omitempty"`
	// Timestamps of writing in partition for client messages.
	// Same size as offsets.
	WrittenAtMs []int64 `protobuf:"varint,5,rep,packed,name=written_at_ms,json=writtenAtMs,proto3" json:"written_at_ms,omitempty"`
	// New messageGroupIds for updating cache.
	// Size of vector is the same as number of negative values in message_group_id_indexes.
	MessageGroupIds []string `protobuf:"bytes,6,rep,name=message_group_ids,json=messageGroupIds,proto3" json:"message_group_ids,omitempty"`
	// Indexes of messageGroupIds.
	// same size as offsets.
	// Negative values (-X) means - put first not used messageGroupId from message_group_ids on index X in cache and use it for this client message.
	// Positive values (X) means -use element by index X from cache for this client message. Do not change state of cache.
	// Assumptions:
	//      - Server will use positive values only for proposed before indexes.
	//      - Each value is from 1 to max_meta_cache_size by abs.
	//      - Do not make assumptions about choosing algorihm.
	//      - There is separate caches of size max_meta_cache_size for different partition and different metadata fileds - message_group_id, ip and session_meta_data.
	//      - Number of negative values in message_group_id_indexes vector is the same as length of message_group_ids vector.
	// Example:
	//                max_meta_cache_size :  2
	//                      Cache indexes :  1  2
	//      Cache state before processing :  s0,? // ? means not set yet.
	//
	//                  message_group_ids :  s1 s2 s3 s1
	//           message_group_id_indexes :  -1    -2    1     2     1     1     -1    2     -2
	//                        cache state :  s1,?  s1,s2 s1,s2 s1,s2 s1,s2 s1,s2 s3,s2 s3,s2 s3,s1
	//             real message group ids :  s1    s2    s1    s2    s1    s1    s3    s2    s1
	//                      Cache indexes :  1  2
	//       Cache state after processing :  s3,s1
	MessageGroupIdIndexes []int64 `` /* 138-byte string literal not displayed */
	// New ips for updating ip cache.
	Ips []string `protobuf:"bytes,8,rep,name=ips,proto3" json:"ips,omitempty"`
	// Same as message_group_id_indexes but for ips.
	IpIndexes []int64 `protobuf:"zigzag64,9,rep,packed,name=ip_indexes,json=ipIndexes,proto3" json:"ip_indexes,omitempty"`
	// New session meta datas for updating cache.
	MessageSessionMeta []*SessionMetaValue `protobuf:"bytes,10,rep,name=message_session_meta,json=messageSessionMeta,proto3" json:"message_session_meta,omitempty"`
	// Same as message_group_id_indexes but for session meta data.
	MessageSessionMetaIndexes []int64 `` /* 151-byte string literal not displayed */
	// Client messages sizes.
	// Same size as offsets.
	MessageSizes []int64 `protobuf:"varint,12,rep,packed,name=message_sizes,json=messageSizes,proto3" json:"message_sizes,omitempty"`
	// Block must contain whole client message when it's size is not bigger that max_block_size.
	// If message is bigger than max_block_size - it will be transferred as SIZE/max_block_size blocks. All of this blocks will be with block_count = 0 but not the last one - last one's block_count will be 0;
	// Blocks can be reordered upto provided by client uncompressed free buffer size.
	// blocks:      A A A B B B CDE
	// offset:      1 1 1 4 4 4 6
	// part_number: 0 1 2 0 1 2 0
	// count:       0 0 1 0 0 1 3
	// Offset will be the same as in Offsets.
	BlocksOffsets     []int64 `protobuf:"varint,13,rep,packed,name=blocks_offsets,json=blocksOffsets,proto3" json:"blocks_offsets,omitempty"`
	BlocksPartNumbers []int64 `protobuf:"varint,14,rep,packed,name=blocks_part_numbers,json=blocksPartNumbers,proto3" json:"blocks_part_numbers,omitempty"`
	// How many complete messages and imcomplete messages end parts (one at most) this block contains
	BlocksMessageCounts     []int64 `` /* 129-byte string literal not displayed */
	BlocksUncompressedSizes []int64 `` /* 141-byte string literal not displayed */
	// In block format version 0 each byte contains only block codec identifier
	BlocksHeaders [][]byte `protobuf:"bytes,17,rep,name=blocks_headers,json=blocksHeaders,proto3" json:"blocks_headers,omitempty"`
	BlocksData    [][]byte `protobuf:"bytes,18,rep,name=blocks_data,json=blocksData,proto3" json:"blocks_data,omitempty"`
	// Zero if this is not first portion of data after resume or provided by client cookie otherwise.
	ResumeCookie         int64                                                                         `protobuf:"varint,50,opt,name=resume_cookie,json=resumeCookie,proto3" json:"resume_cookie,omitempty"`
	ReadStatistics       *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics `protobuf:"bytes,100,opt,name=read_statistics,json=readStatistics,proto3" json:"read_statistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                                                      `json:"-"`
	XXX_unrecognized     []byte                                                                        `json:"-"`
	XXX_sizecache        int32                                                                         `json:"-"`
}

One client message representation. Client lib must send commit right now for all skipped data (from it's read offset till first offset in range).

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) Descriptor 

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

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksData 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksData() [][]byte

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksHeaders 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksHeaders() [][]byte

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksMessageCounts 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksMessageCounts() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksOffsets 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksOffsets() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksPartNumbers 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksPartNumbers() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksUncompressedSizes 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetBlocksUncompressedSizes() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetCreatedAtMs 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetCreatedAtMs() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetIpIndexes 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetIpIndexes() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetIps 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetIps() []string

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageGroupIdIndexes 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageGroupIdIndexes() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageGroupIds 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageGroupIds() []string

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSessionMeta 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSessionMeta() []*SessionMetaValue

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSessionMetaIndexes 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSessionMetaIndexes() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSizes 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetMessageSizes() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetOffsets 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetOffsets() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetPartitionStreamId 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetPartitionStreamId() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetReadStatistics 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetReadStatistics() *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetResumeCookie 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetResumeCookie() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetSequenceNumbers 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetSequenceNumbers() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetWrittenAtMs 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) GetWrittenAtMs() []int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) ProtoMessage 

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) ProtoMessage()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) Reset 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) Reset()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) String 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) String() string

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Marshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Merge 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Size 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Size() int

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics 

type StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics struct {
	BlobsFromCache       int64    `protobuf:"varint,1,opt,name=blobs_from_cache,json=blobsFromCache,proto3" json:"blobs_from_cache,omitempty"`
	BlobsFromDisk        int64    `protobuf:"varint,2,opt,name=blobs_from_disk,json=blobsFromDisk,proto3" json:"blobs_from_disk,omitempty"`
	BytesFromHead        int64    `protobuf:"varint,3,opt,name=bytes_from_head,json=bytesFromHead,proto3" json:"bytes_from_head,omitempty"`
	BytesFromCache       int64    `protobuf:"varint,4,opt,name=bytes_from_cache,json=bytesFromCache,proto3" json:"bytes_from_cache,omitempty"`
	BytesFromDisk        int64    `protobuf:"varint,5,opt,name=bytes_from_disk,json=bytesFromDisk,proto3" json:"bytes_from_disk,omitempty"`
	RepackDurationMs     int64    `protobuf:"varint,6,opt,name=repack_duration_ms,json=repackDurationMs,proto3" json:"repack_duration_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) Descriptor 

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

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBlobsFromCache 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBlobsFromCache() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBlobsFromDisk 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBlobsFromDisk() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromCache 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromCache() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromDisk 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromDisk() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromHead 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetBytesFromHead() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetRepackDurationMs 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) GetRepackDurationMs() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) ProtoMessage 

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) ProtoMessage()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) Reset 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) Reset()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) String 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) String() string

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Marshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Merge 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Size 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Size() int

func (*StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_PartitionData_ReadStatistics) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_BatchReadResponse_SkipRange 

type StreamingReadServerMessageNew_BatchReadResponse_SkipRange struct {
	// Partition Stream identifier.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// When some data is skipped by client parameters (read_timestamp_ms for example) then range of skipped offsets is sended to client.
	// Client lib must commit this range and change read_offset to end of this range.
	SkipRange            *OffsetsRange `protobuf:"bytes,2,opt,name=skip_range,json=skipRange,proto3" json:"skip_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) Descriptor 

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

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) GetPartitionStreamId 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) GetPartitionStreamId() int64

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) GetSkipRange 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) GetSkipRange() *OffsetsRange

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) ProtoMessage 

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) ProtoMessage()

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) Reset 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) Reset()

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) String 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) String() string

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Marshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Merge 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Size 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Size() int

func (*StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_BatchReadResponse_SkipRange) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_CommitResponse 

type StreamingReadServerMessageNew_CommitResponse struct {
	// Partitions with progress.
	PartitionsCommittedOffsets []*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral       struct{}                                                                 `json:"-"`
	XXX_unrecognized           []byte                                                                   `json:"-"`
	XXX_sizecache              int32                                                                    `json:"-"`
}

Acknowledgement for commits.

func (*StreamingReadServerMessageNew_CommitResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_CommitResponse) GetPartitionsCommittedOffsets 

func (m *StreamingReadServerMessageNew_CommitResponse) GetPartitionsCommittedOffsets() []*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset

func (*StreamingReadServerMessageNew_CommitResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_CommitResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_CommitResponse) Reset 

func (m *StreamingReadServerMessageNew_CommitResponse) Reset()

func (*StreamingReadServerMessageNew_CommitResponse) String 

func (m *StreamingReadServerMessageNew_CommitResponse) String() string

func (*StreamingReadServerMessageNew_CommitResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_CommitResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_CommitResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_CommitResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_CommitResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_CommitResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_CommitResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_CommitResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_CommitResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_CommitResponse_ 

type StreamingReadServerMessageNew_CommitResponse_ struct {
	CommitResponse *StreamingReadServerMessageNew_CommitResponse `protobuf:"bytes,7,opt,name=commit_response,json=commitResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset 

type StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset struct {
	// Partition partition stream identifier.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Last committed offset.
	CommittedOffset      int64    `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Per-partition commit representation.

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) Descriptor 

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

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) GetCommittedOffset 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) GetCommittedOffset() int64

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) GetPartitionStreamId 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) GetPartitionStreamId() int64

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) ProtoMessage 

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) ProtoMessage()

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) Reset 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) Reset()

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) String 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) String() string

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Marshal 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Merge 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Size 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Size() int

func (*StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_CommitResponse_PartitionCommittedOffset) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_CreatePartitionStreamRequest 

type StreamingReadServerMessageNew_CreatePartitionStreamRequest struct {
	// Partition partition stream description.
	PartitionStream *PartitionStream `protobuf:"bytes,1,opt,name=partition_stream,json=partitionStream,proto3" json:"partition_stream,omitempty"`
	// Actual committed offset.
	CommittedOffset int64 `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// Offset of first not existing message in partition till now.
	EndOffset            int64    `protobuf:"varint,3,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Command to create a partition partition stream. Client must react on this signal by sending StartRead when ready recieve data from this partition.

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) Descriptor 

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

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetCommittedOffset 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetCommittedOffset() int64

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetEndOffset 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetEndOffset() int64

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetPartitionStream 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) GetPartitionStream() *PartitionStream

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) ProtoMessage 

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) ProtoMessage()

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) Reset 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) Reset()

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) String 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) String() string

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Marshal 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Merge 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Size 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Size() int

func (*StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_CreatePartitionStreamRequest) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_CreatePartitionStreamRequest_ 

type StreamingReadServerMessageNew_CreatePartitionStreamRequest_ struct {
	CreatePartitionStreamRequest *StreamingReadServerMessageNew_CreatePartitionStreamRequest `protobuf:"bytes,5,opt,name=create_partition_stream_request,json=createPartitionStreamRequest,proto3,oneof"`
}

type StreamingReadServerMessageNew_DestroyPartitionStreamRequest 

type StreamingReadServerMessageNew_DestroyPartitionStreamRequest struct {
	// Identifier of partition partition stream that is ready to be closed by server.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	// Flag of gracefull or not destroy.
	// If True then server is waiting for Destroyed signal from client before giving of this partition for other read session.
	// Server will not send more data from this partition.
	// Client can process all received data and wait for commit and only after send Destroyed signal.
	// If False then server gives partition for other session right now.
	// All futher commits for this PartitionStream has no effect. Server is not waiting for Destroyed signal.
	Graceful bool `protobuf:"varint,2,opt,name=graceful,proto3" json:"graceful,omitempty"`
	// Last known committed offset.
	CommittedOffset      int64    `protobuf:"varint,3,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Command to destroy concrete partition stream.

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) Descriptor 

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

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetCommittedOffset 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetCommittedOffset() int64

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetGraceful 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetGraceful() bool

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetPartitionStreamId 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) GetPartitionStreamId() int64

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) ProtoMessage 

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) ProtoMessage()

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) Reset 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) Reset()

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) String 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) String() string

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Marshal 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Merge 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Size 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Size() int

func (*StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_DestroyPartitionStreamRequest) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_DestroyPartitionStreamRequest_ 

type StreamingReadServerMessageNew_DestroyPartitionStreamRequest_ struct {
	DestroyPartitionStreamRequest *StreamingReadServerMessageNew_DestroyPartitionStreamRequest `protobuf:"bytes,6,opt,name=destroy_partition_stream_request,json=destroyPartitionStreamRequest,proto3,oneof"`
}

type StreamingReadServerMessageNew_InitResponse 

type StreamingReadServerMessageNew_InitResponse struct {
	// Read session identifier for debug purposes.
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Block format version of data client will receive from topics.
	BlockFormatVersionByTopic map[string]int64 `` /* 231-byte string literal not displayed */
	// Choosed maximan cache size by server.
	// Client must use cache of this size. Could change on retries - reduce size of cache in this case.
	MaxMetaCacheSize     int64    `protobuf:"varint,10,opt,name=max_meta_cache_size,json=maxMetaCacheSize,proto3" json:"max_meta_cache_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Handshake response.

func (*StreamingReadServerMessageNew_InitResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_InitResponse) GetBlockFormatVersionByTopic 

func (m *StreamingReadServerMessageNew_InitResponse) GetBlockFormatVersionByTopic() map[string]int64

func (*StreamingReadServerMessageNew_InitResponse) GetMaxMetaCacheSize 

func (m *StreamingReadServerMessageNew_InitResponse) GetMaxMetaCacheSize() int64

func (*StreamingReadServerMessageNew_InitResponse) GetSessionId 

func (m *StreamingReadServerMessageNew_InitResponse) GetSessionId() string

func (*StreamingReadServerMessageNew_InitResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_InitResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_InitResponse) Reset 

func (m *StreamingReadServerMessageNew_InitResponse) Reset()

func (*StreamingReadServerMessageNew_InitResponse) String 

func (m *StreamingReadServerMessageNew_InitResponse) String() string

func (*StreamingReadServerMessageNew_InitResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_InitResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_InitResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_InitResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_InitResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_InitResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_InitResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_InitResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_InitResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_InitResponse_ 

type StreamingReadServerMessageNew_InitResponse_ struct {
	InitResponse *StreamingReadServerMessageNew_InitResponse `protobuf:"bytes,3,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_PartitionStreamStatusResponse 

type StreamingReadServerMessageNew_PartitionStreamStatusResponse struct {
	// Identifier of partition partition stream that is ready to be closed by server.
	PartitionStreamId int64 `protobuf:"varint,1,opt,name=partition_stream_id,json=partitionStreamId,proto3" json:"partition_stream_id,omitempty"`
	CommittedOffset   int64 `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	EndOffset         int64 `protobuf:"varint,3,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	// WriteTimestamp of next message (and end_offset) will be not less that WriteWatermarkMs.
	WrittenAtWatermarkMs int64    `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for status requst.

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetCommittedOffset 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetCommittedOffset() int64

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetEndOffset 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetEndOffset() int64

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetPartitionStreamId 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetPartitionStreamId() int64

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetWrittenAtWatermarkMs 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) GetWrittenAtWatermarkMs() int64

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) Reset 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) Reset()

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) String 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) String() string

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_PartitionStreamStatusResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_PartitionStreamStatusResponse_ 

type StreamingReadServerMessageNew_PartitionStreamStatusResponse_ struct {
	PartitionStreamStatusResponse *StreamingReadServerMessageNew_PartitionStreamStatusResponse `protobuf:"bytes,8,opt,name=partition_stream_status_response,json=partitionStreamStatusResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_RemoveTopicResponse 

type StreamingReadServerMessageNew_RemoveTopicResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadServerMessageNew_RemoveTopicResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_RemoveTopicResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_RemoveTopicResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_RemoveTopicResponse) Reset 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) Reset()

func (*StreamingReadServerMessageNew_RemoveTopicResponse) String 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) String() string

func (*StreamingReadServerMessageNew_RemoveTopicResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_RemoveTopicResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_RemoveTopicResponse_ 

type StreamingReadServerMessageNew_RemoveTopicResponse_ struct {
	RemoveTopicResponse *StreamingReadServerMessageNew_RemoveTopicResponse `protobuf:"bytes,12,opt,name=remove_topic_response,json=removeTopicResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_ResumeReadResponse 

type StreamingReadServerMessageNew_ResumeReadResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadServerMessageNew_ResumeReadResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_ResumeReadResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_ResumeReadResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_ResumeReadResponse) Reset 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) Reset()

func (*StreamingReadServerMessageNew_ResumeReadResponse) String 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) String() string

func (*StreamingReadServerMessageNew_ResumeReadResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_ResumeReadResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_ResumeReadResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_ResumeReadResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_ResumeReadResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_ResumeReadResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_ResumeReadResponse_ 

type StreamingReadServerMessageNew_ResumeReadResponse_ struct {
	ResumeReadResponse *StreamingReadServerMessageNew_ResumeReadResponse `protobuf:"bytes,10,opt,name=resume_read_response,json=resumeReadResponse,proto3,oneof"`
}

type StreamingReadServerMessageNew_StopReadResponse 

type StreamingReadServerMessageNew_StopReadResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingReadServerMessageNew_StopReadResponse) Descriptor 

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

func (*StreamingReadServerMessageNew_StopReadResponse) ProtoMessage 

func (*StreamingReadServerMessageNew_StopReadResponse) ProtoMessage()

func (*StreamingReadServerMessageNew_StopReadResponse) Reset 

func (m *StreamingReadServerMessageNew_StopReadResponse) Reset()

func (*StreamingReadServerMessageNew_StopReadResponse) String 

func (m *StreamingReadServerMessageNew_StopReadResponse) String() string

func (*StreamingReadServerMessageNew_StopReadResponse) XXX_DiscardUnknown 

func (m *StreamingReadServerMessageNew_StopReadResponse) XXX_DiscardUnknown()

func (*StreamingReadServerMessageNew_StopReadResponse) XXX_Marshal 

func (m *StreamingReadServerMessageNew_StopReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingReadServerMessageNew_StopReadResponse) XXX_Merge 

func (m *StreamingReadServerMessageNew_StopReadResponse) XXX_Merge(src proto.Message)

func (*StreamingReadServerMessageNew_StopReadResponse) XXX_Size 

func (m *StreamingReadServerMessageNew_StopReadResponse) XXX_Size() int

func (*StreamingReadServerMessageNew_StopReadResponse) XXX_Unmarshal 

func (m *StreamingReadServerMessageNew_StopReadResponse) XXX_Unmarshal(b []byte) error

type StreamingReadServerMessageNew_StopReadResponse_ 

type StreamingReadServerMessageNew_StopReadResponse_ struct {
	StopReadResponse *StreamingReadServerMessageNew_StopReadResponse `protobuf:"bytes,9,opt,name=stop_read_response,json=stopReadResponse,proto3,oneof"`
}

type StreamingWriteClientMessage 

type StreamingWriteClientMessage struct {
	// Types that are valid to be assigned to ClientMessage:
	//	*StreamingWriteClientMessage_InitRequest_
	//	*StreamingWriteClientMessage_WriteRequest_
	//	*StreamingWriteClientMessage_UpdateTokenRequest_
	ClientMessage        isStreamingWriteClientMessage_ClientMessage `protobuf_oneof:"client_message"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

* Request for write session. Contains one of: 

InitRequest - handshake request.
WriteRequest - portion of data to be written.
UpdateTokenRequest - user credentials if update is needed.

func (*StreamingWriteClientMessage) Descriptor 

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

func (*StreamingWriteClientMessage) GetClientMessage 

func (m *StreamingWriteClientMessage) GetClientMessage() isStreamingWriteClientMessage_ClientMessage

func (*StreamingWriteClientMessage) GetInitRequest 

func (m *StreamingWriteClientMessage) GetInitRequest() *StreamingWriteClientMessage_InitRequest

func (*StreamingWriteClientMessage) GetUpdateTokenRequest 

func (m *StreamingWriteClientMessage) GetUpdateTokenRequest() *StreamingWriteClientMessage_UpdateTokenRequest

func (*StreamingWriteClientMessage) GetWriteRequest 

func (m *StreamingWriteClientMessage) GetWriteRequest() *StreamingWriteClientMessage_WriteRequest

func (*StreamingWriteClientMessage) ProtoMessage 

func (*StreamingWriteClientMessage) ProtoMessage()

func (*StreamingWriteClientMessage) Reset 

func (m *StreamingWriteClientMessage) Reset()

func (*StreamingWriteClientMessage) String 

func (m *StreamingWriteClientMessage) String() string

func (*StreamingWriteClientMessage) XXX_DiscardUnknown 

func (m *StreamingWriteClientMessage) XXX_DiscardUnknown()

func (*StreamingWriteClientMessage) XXX_Marshal 

func (m *StreamingWriteClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteClientMessage) XXX_Merge 

func (m *StreamingWriteClientMessage) XXX_Merge(src proto.Message)

func (*StreamingWriteClientMessage) XXX_OneofWrappers 

func (*StreamingWriteClientMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamingWriteClientMessage) XXX_Size 

func (m *StreamingWriteClientMessage) XXX_Size() int

func (*StreamingWriteClientMessage) XXX_Unmarshal 

func (m *StreamingWriteClientMessage) XXX_Unmarshal(b []byte) error

type StreamingWriteClientMessage_InitRequest 

type StreamingWriteClientMessage_InitRequest struct {
	// Path of topic to write to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// message group identifier of client data stream a.k.a. sourceId.
	MessageGroupId string `protobuf:"bytes,2,opt,name=message_group_id,json=messageGroupId,proto3" json:"message_group_id,omitempty"`
	// Some user metadata attached to this write session.
	SessionMeta map[string]string `` /* 182-byte string literal not displayed */
	// Partition group to write to.
	// Zero means any group.
	PartitionGroupId               int64  `protobuf:"varint,4,opt,name=partition_group_id,json=partitionGroupId,proto3" json:"partition_group_id,omitempty"`
	MaxSupportedBlockFormatVersion int64  `` /* 158-byte string literal not displayed */
	SessionId                      string `protobuf:"bytes,100,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// 0 for first init message and incremental value for connect retries. Used for server logging.
	ConnectionAttempt int64 `protobuf:"varint,101,opt,name=connection_attempt,json=connectionAttempt,proto3" json:"connection_attempt,omitempty"`
	// Opaque blob. Take last one from previous connect.
	ConnectionMeta []byte `protobuf:"bytes,102,opt,name=connection_meta,json=connectionMeta,proto3" json:"connection_meta,omitempty"`
	// Optinal preferred cluster name. Sever will close session If preferred cluster is not server cluster and preferred cluster is enabled after delay TPQConfig::CloseClientSessionWithEnabledRemotePreferredClusterDelaySec
	PreferredCluster string `protobuf:"bytes,103,opt,name=preferred_cluster,json=preferredCluster,proto3" json:"preferred_cluster,omitempty"`
	// Sanity check option. When no writing activity is done in idle_timeout_sec seconds, then session will be destroyed. Zero means infinity.
	IdleTimeoutMs        int64    `protobuf:"varint,200,opt,name=idle_timeout_ms,json=idleTimeoutMs,proto3" json:"idle_timeout_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Handshake request that must be sent to server first.

func (*StreamingWriteClientMessage_InitRequest) Descriptor 

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

func (*StreamingWriteClientMessage_InitRequest) GetConnectionAttempt 

func (m *StreamingWriteClientMessage_InitRequest) GetConnectionAttempt() int64

func (*StreamingWriteClientMessage_InitRequest) GetConnectionMeta 

func (m *StreamingWriteClientMessage_InitRequest) GetConnectionMeta() []byte

func (*StreamingWriteClientMessage_InitRequest) GetIdleTimeoutMs 

func (m *StreamingWriteClientMessage_InitRequest) GetIdleTimeoutMs() int64

func (*StreamingWriteClientMessage_InitRequest) GetMaxSupportedBlockFormatVersion 

func (m *StreamingWriteClientMessage_InitRequest) GetMaxSupportedBlockFormatVersion() int64

func (*StreamingWriteClientMessage_InitRequest) GetMessageGroupId 

func (m *StreamingWriteClientMessage_InitRequest) GetMessageGroupId() string

func (*StreamingWriteClientMessage_InitRequest) GetPartitionGroupId 

func (m *StreamingWriteClientMessage_InitRequest) GetPartitionGroupId() int64

func (*StreamingWriteClientMessage_InitRequest) GetPreferredCluster 

func (m *StreamingWriteClientMessage_InitRequest) GetPreferredCluster() string

func (*StreamingWriteClientMessage_InitRequest) GetSessionId 

func (m *StreamingWriteClientMessage_InitRequest) GetSessionId() string

func (*StreamingWriteClientMessage_InitRequest) GetSessionMeta 

func (m *StreamingWriteClientMessage_InitRequest) GetSessionMeta() map[string]string

func (*StreamingWriteClientMessage_InitRequest) GetTopic 

func (m *StreamingWriteClientMessage_InitRequest) GetTopic() string

func (*StreamingWriteClientMessage_InitRequest) ProtoMessage 

func (*StreamingWriteClientMessage_InitRequest) ProtoMessage()

func (*StreamingWriteClientMessage_InitRequest) Reset 

func (m *StreamingWriteClientMessage_InitRequest) Reset()

func (*StreamingWriteClientMessage_InitRequest) String 

func (m *StreamingWriteClientMessage_InitRequest) String() string

func (*StreamingWriteClientMessage_InitRequest) XXX_DiscardUnknown 

func (m *StreamingWriteClientMessage_InitRequest) XXX_DiscardUnknown()

func (*StreamingWriteClientMessage_InitRequest) XXX_Marshal 

func (m *StreamingWriteClientMessage_InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteClientMessage_InitRequest) XXX_Merge 

func (m *StreamingWriteClientMessage_InitRequest) XXX_Merge(src proto.Message)

func (*StreamingWriteClientMessage_InitRequest) XXX_Size 

func (m *StreamingWriteClientMessage_InitRequest) XXX_Size() int

func (*StreamingWriteClientMessage_InitRequest) XXX_Unmarshal 

func (m *StreamingWriteClientMessage_InitRequest) XXX_Unmarshal(b []byte) error

type StreamingWriteClientMessage_InitRequest_ 

type StreamingWriteClientMessage_InitRequest_ struct {
	InitRequest *StreamingWriteClientMessage_InitRequest `protobuf:"bytes,1,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type StreamingWriteClientMessage_UpdateTokenRequest 

type StreamingWriteClientMessage_UpdateTokenRequest struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

In-session reauthentication and reauthorization, lets user increase session lifetime. You should wait for 'update_token_response' before sending next 'update_token_request'.

func (*StreamingWriteClientMessage_UpdateTokenRequest) Descriptor 

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

func (*StreamingWriteClientMessage_UpdateTokenRequest) GetToken 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) GetToken() string

func (*StreamingWriteClientMessage_UpdateTokenRequest) ProtoMessage 

func (*StreamingWriteClientMessage_UpdateTokenRequest) ProtoMessage()

func (*StreamingWriteClientMessage_UpdateTokenRequest) Reset 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) Reset()

func (*StreamingWriteClientMessage_UpdateTokenRequest) String 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) String() string

func (*StreamingWriteClientMessage_UpdateTokenRequest) XXX_DiscardUnknown 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) XXX_DiscardUnknown()

func (*StreamingWriteClientMessage_UpdateTokenRequest) XXX_Marshal 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteClientMessage_UpdateTokenRequest) XXX_Merge 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) XXX_Merge(src proto.Message)

func (*StreamingWriteClientMessage_UpdateTokenRequest) XXX_Size 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) XXX_Size() int

func (*StreamingWriteClientMessage_UpdateTokenRequest) XXX_Unmarshal 

func (m *StreamingWriteClientMessage_UpdateTokenRequest) XXX_Unmarshal(b []byte) error

type StreamingWriteClientMessage_UpdateTokenRequest_ 

type StreamingWriteClientMessage_UpdateTokenRequest_ struct {
	UpdateTokenRequest *StreamingWriteClientMessage_UpdateTokenRequest `protobuf:"bytes,3,opt,name=update_token_request,json=updateTokenRequest,proto3,oneof"`
}

type StreamingWriteClientMessage_WriteRequest 

type StreamingWriteClientMessage_WriteRequest struct {
	// Sequence numbers of messages in order that client will provide to server.
	SequenceNumbers []int64 `protobuf:"varint,2,rep,packed,name=sequence_numbers,json=sequenceNumbers,proto3" json:"sequence_numbers,omitempty"`
	// Message creation timestamps for client messages.
	// Same size as sequence_numbers.
	CreatedAtMs []int64 `protobuf:"varint,3,rep,packed,name=created_at_ms,json=createdAtMs,proto3" json:"created_at_ms,omitempty"`
	// Message creation timestamps for client messages.
	// Same size as sequence_numbers.
	SentAtMs []int64 `protobuf:"varint,4,rep,packed,name=sent_at_ms,json=sentAtMs,proto3" json:"sent_at_ms,omitempty"`
	// Client message sizes.
	// Same size as sequence_numbers.
	MessageSizes      []int64 `protobuf:"varint,5,rep,packed,name=message_sizes,json=messageSizes,proto3" json:"message_sizes,omitempty"`
	BlocksOffsets     []int64 `protobuf:"varint,6,rep,packed,name=blocks_offsets,json=blocksOffsets,proto3" json:"blocks_offsets,omitempty"`
	BlocksPartNumbers []int64 `protobuf:"varint,7,rep,packed,name=blocks_part_numbers,json=blocksPartNumbers,proto3" json:"blocks_part_numbers,omitempty"`
	// How many complete messages and imcomplete messages end parts (one at most) this block contains
	BlocksMessageCounts     []int64 `` /* 128-byte string literal not displayed */
	BlocksUncompressedSizes []int64 `` /* 140-byte string literal not displayed */
	// In block format version 0 each byte contains only block codec identifier
	BlocksHeaders        [][]byte `protobuf:"bytes,10,rep,name=blocks_headers,json=blocksHeaders,proto3" json:"blocks_headers,omitempty"`
	BlocksData           [][]byte `protobuf:"bytes,11,rep,name=blocks_data,json=blocksData,proto3" json:"blocks_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents portion of client messages.

func (*StreamingWriteClientMessage_WriteRequest) Descriptor 

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

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksData 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksData() [][]byte

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksHeaders 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksHeaders() [][]byte

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksMessageCounts 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksMessageCounts() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksOffsets 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksOffsets() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksPartNumbers 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksPartNumbers() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetBlocksUncompressedSizes 

func (m *StreamingWriteClientMessage_WriteRequest) GetBlocksUncompressedSizes() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetCreatedAtMs 

func (m *StreamingWriteClientMessage_WriteRequest) GetCreatedAtMs() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetMessageSizes 

func (m *StreamingWriteClientMessage_WriteRequest) GetMessageSizes() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetSentAtMs 

func (m *StreamingWriteClientMessage_WriteRequest) GetSentAtMs() []int64

func (*StreamingWriteClientMessage_WriteRequest) GetSequenceNumbers 

func (m *StreamingWriteClientMessage_WriteRequest) GetSequenceNumbers() []int64

func (*StreamingWriteClientMessage_WriteRequest) ProtoMessage 

func (*StreamingWriteClientMessage_WriteRequest) ProtoMessage()

func (*StreamingWriteClientMessage_WriteRequest) Reset 

func (m *StreamingWriteClientMessage_WriteRequest) Reset()

func (*StreamingWriteClientMessage_WriteRequest) String 

func (m *StreamingWriteClientMessage_WriteRequest) String() string

func (*StreamingWriteClientMessage_WriteRequest) XXX_DiscardUnknown 

func (m *StreamingWriteClientMessage_WriteRequest) XXX_DiscardUnknown()

func (*StreamingWriteClientMessage_WriteRequest) XXX_Marshal 

func (m *StreamingWriteClientMessage_WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteClientMessage_WriteRequest) XXX_Merge 

func (m *StreamingWriteClientMessage_WriteRequest) XXX_Merge(src proto.Message)

func (*StreamingWriteClientMessage_WriteRequest) XXX_Size 

func (m *StreamingWriteClientMessage_WriteRequest) XXX_Size() int

func (*StreamingWriteClientMessage_WriteRequest) XXX_Unmarshal 

func (m *StreamingWriteClientMessage_WriteRequest) XXX_Unmarshal(b []byte) error

type StreamingWriteClientMessage_WriteRequest_ 

type StreamingWriteClientMessage_WriteRequest_ struct {
	WriteRequest *StreamingWriteClientMessage_WriteRequest `protobuf:"bytes,2,opt,name=write_request,json=writeRequest,proto3,oneof"`
}

type StreamingWriteServerMessage 

type StreamingWriteServerMessage struct {
	// Types that are valid to be assigned to ServerMessage:
	//	*StreamingWriteServerMessage_InitResponse_
	//	*StreamingWriteServerMessage_BatchWriteResponse_
	//	*StreamingWriteServerMessage_UpdateTokenResponse_
	ServerMessage isStreamingWriteServerMessage_ServerMessage `protobuf_oneof:"server_message"`
	// Server status of response.
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues if any.
	Issues               []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* Response for write session. Contains one of: 

InitResponse - correct handshake response.
BatchWriteResponse - acknowledgment of storing client messages.
UpdateTokenResponse - acknowledgment of reauthentication and reauthorization.

func (*StreamingWriteServerMessage) Descriptor 

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

func (*StreamingWriteServerMessage) GetBatchWriteResponse 

func (m *StreamingWriteServerMessage) GetBatchWriteResponse() *StreamingWriteServerMessage_BatchWriteResponse

func (*StreamingWriteServerMessage) GetInitResponse 

func (m *StreamingWriteServerMessage) GetInitResponse() *StreamingWriteServerMessage_InitResponse

func (*StreamingWriteServerMessage) GetIssues 

func (m *StreamingWriteServerMessage) GetIssues() []*Ydb_Issue.IssueMessage

func (*StreamingWriteServerMessage) GetServerMessage 

func (m *StreamingWriteServerMessage) GetServerMessage() isStreamingWriteServerMessage_ServerMessage

func (*StreamingWriteServerMessage) GetStatus 

func (m *StreamingWriteServerMessage) GetStatus() Ydb.StatusIds_StatusCode

func (*StreamingWriteServerMessage) GetUpdateTokenResponse 

func (m *StreamingWriteServerMessage) GetUpdateTokenResponse() *StreamingWriteServerMessage_UpdateTokenResponse

func (*StreamingWriteServerMessage) ProtoMessage 

func (*StreamingWriteServerMessage) ProtoMessage()

func (*StreamingWriteServerMessage) Reset 

func (m *StreamingWriteServerMessage) Reset()

func (*StreamingWriteServerMessage) String 

func (m *StreamingWriteServerMessage) String() string

func (*StreamingWriteServerMessage) XXX_DiscardUnknown 

func (m *StreamingWriteServerMessage) XXX_DiscardUnknown()

func (*StreamingWriteServerMessage) XXX_Marshal 

func (m *StreamingWriteServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteServerMessage) XXX_Merge 

func (m *StreamingWriteServerMessage) XXX_Merge(src proto.Message)

func (*StreamingWriteServerMessage) XXX_OneofWrappers 

func (*StreamingWriteServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamingWriteServerMessage) XXX_Size 

func (m *StreamingWriteServerMessage) XXX_Size() int

func (*StreamingWriteServerMessage) XXX_Unmarshal 

func (m *StreamingWriteServerMessage) XXX_Unmarshal(b []byte) error

type StreamingWriteServerMessage_BatchWriteResponse 

type StreamingWriteServerMessage_BatchWriteResponse struct {
	// Sequence numbers of persisted client messages.
	SequenceNumbers []int64 `protobuf:"varint,1,rep,packed,name=sequence_numbers,json=sequenceNumbers,proto3" json:"sequence_numbers,omitempty"`
	// Assigned partition offsets.
	// Zero for skipped messages.
	Offsets []int64 `protobuf:"varint,2,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	// Per message flag. False if message is written for the first time and True otherwise.
	AlreadyWritten []bool `protobuf:"varint,3,rep,packed,name=already_written,json=alreadyWritten,proto3" json:"already_written,omitempty"`
	// Assigned partition for all client messages inside this batch.
	PartitionId int64 `protobuf:"varint,4,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Write statistics for this sequence of client messages.
	WriteStatistics      *StreamingWriteServerMessage_WriteStatistics `protobuf:"bytes,5,opt,name=write_statistics,json=writeStatistics,proto3" json:"write_statistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

Message that represents acknowledgment for sequence of client messages. This sequence is persisted together so write statistics is for messages batch.

func (*StreamingWriteServerMessage_BatchWriteResponse) Descriptor 

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

func (*StreamingWriteServerMessage_BatchWriteResponse) GetAlreadyWritten 

func (m *StreamingWriteServerMessage_BatchWriteResponse) GetAlreadyWritten() []bool

func (*StreamingWriteServerMessage_BatchWriteResponse) GetOffsets 

func (m *StreamingWriteServerMessage_BatchWriteResponse) GetOffsets() []int64

func (*StreamingWriteServerMessage_BatchWriteResponse) GetPartitionId 

func (m *StreamingWriteServerMessage_BatchWriteResponse) GetPartitionId() int64

func (*StreamingWriteServerMessage_BatchWriteResponse) GetSequenceNumbers 

func (m *StreamingWriteServerMessage_BatchWriteResponse) GetSequenceNumbers() []int64

func (*StreamingWriteServerMessage_BatchWriteResponse) GetWriteStatistics 

func (m *StreamingWriteServerMessage_BatchWriteResponse) GetWriteStatistics() *StreamingWriteServerMessage_WriteStatistics

func (*StreamingWriteServerMessage_BatchWriteResponse) ProtoMessage 

func (*StreamingWriteServerMessage_BatchWriteResponse) ProtoMessage()

func (*StreamingWriteServerMessage_BatchWriteResponse) Reset 

func (m *StreamingWriteServerMessage_BatchWriteResponse) Reset()

func (*StreamingWriteServerMessage_BatchWriteResponse) String 

func (m *StreamingWriteServerMessage_BatchWriteResponse) String() string

func (*StreamingWriteServerMessage_BatchWriteResponse) XXX_DiscardUnknown 

func (m *StreamingWriteServerMessage_BatchWriteResponse) XXX_DiscardUnknown()

func (*StreamingWriteServerMessage_BatchWriteResponse) XXX_Marshal 

func (m *StreamingWriteServerMessage_BatchWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteServerMessage_BatchWriteResponse) XXX_Merge 

func (m *StreamingWriteServerMessage_BatchWriteResponse) XXX_Merge(src proto.Message)

func (*StreamingWriteServerMessage_BatchWriteResponse) XXX_Size 

func (m *StreamingWriteServerMessage_BatchWriteResponse) XXX_Size() int

func (*StreamingWriteServerMessage_BatchWriteResponse) XXX_Unmarshal 

func (m *StreamingWriteServerMessage_BatchWriteResponse) XXX_Unmarshal(b []byte) error

type StreamingWriteServerMessage_BatchWriteResponse_ 

type StreamingWriteServerMessage_BatchWriteResponse_ struct {
	BatchWriteResponse *StreamingWriteServerMessage_BatchWriteResponse `protobuf:"bytes,4,opt,name=batch_write_response,json=batchWriteResponse,proto3,oneof"`
}

type StreamingWriteServerMessage_InitResponse 

type StreamingWriteServerMessage_InitResponse struct {
	// Last persisted message's sequence number for this message group.
	LastSequenceNumber int64 `protobuf:"varint,1,opt,name=last_sequence_number,json=lastSequenceNumber,proto3" json:"last_sequence_number,omitempty"`
	// Unique identifier of write session. Used for debug purposes.
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Path of topic that matched for this write session. Used for debug purposes, will be the same as in Init request from client.
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// Write session is established to this cluster. Client data will be in instance of topic in this cluster.
	Cluster string `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Identifier of partition that is matched for this write session.
	PartitionId int64 `protobuf:"varint,5,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Block (see StreamingWriteClientMessage.WriteRequest.blocks_data) format version supported by server or configured for a topic. Client must write data only with them.
	BlockFormatVersion int64 `protobuf:"varint,6,opt,name=block_format_version,json=blockFormatVersion,proto3" json:"block_format_version,omitempty"`
	// Client can only use compression codecs from this set to write messages to topic, session will be closed with BAD_REQUEST otherwise.
	SupportedCodecs []Codec `` /* 143-byte string literal not displayed */
	// Maximal flush window size choosed by server. Size of uncompressed data not sended to server must not be bigger than flush window size.
	// In other words, this is maximal size of gap inside uncompressed data, which is not sended to server yet.
	MaxFlushWindowSize int64 `protobuf:"varint,7,opt,name=max_flush_window_size,json=maxFlushWindowSize,proto3" json:"max_flush_window_size,omitempty"`
	// How big blocks per stream could be(in uncompressed size). When block contains more than max_block_size of uncompressed data - block must be truncated.
	MaxBlockSize int64 `protobuf:"varint,8,opt,name=max_block_size,json=maxBlockSize,proto3" json:"max_block_size,omitempty"`
	// Opaque blob, used for fast reconnects.
	ConnectionMeta       []byte   `protobuf:"bytes,9,opt,name=connection_meta,json=connectionMeta,proto3" json:"connection_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for handshake.

func (*StreamingWriteServerMessage_InitResponse) Descriptor 

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

func (*StreamingWriteServerMessage_InitResponse) GetBlockFormatVersion 

func (m *StreamingWriteServerMessage_InitResponse) GetBlockFormatVersion() int64

func (*StreamingWriteServerMessage_InitResponse) GetCluster 

func (m *StreamingWriteServerMessage_InitResponse) GetCluster() string

func (*StreamingWriteServerMessage_InitResponse) GetConnectionMeta 

func (m *StreamingWriteServerMessage_InitResponse) GetConnectionMeta() []byte

func (*StreamingWriteServerMessage_InitResponse) GetLastSequenceNumber 

func (m *StreamingWriteServerMessage_InitResponse) GetLastSequenceNumber() int64

func (*StreamingWriteServerMessage_InitResponse) GetMaxBlockSize 

func (m *StreamingWriteServerMessage_InitResponse) GetMaxBlockSize() int64

func (*StreamingWriteServerMessage_InitResponse) GetMaxFlushWindowSize 

func (m *StreamingWriteServerMessage_InitResponse) GetMaxFlushWindowSize() int64

func (*StreamingWriteServerMessage_InitResponse) GetPartitionId 

func (m *StreamingWriteServerMessage_InitResponse) GetPartitionId() int64

func (*StreamingWriteServerMessage_InitResponse) GetSessionId 

func (m *StreamingWriteServerMessage_InitResponse) GetSessionId() string

func (*StreamingWriteServerMessage_InitResponse) GetSupportedCodecs 

func (m *StreamingWriteServerMessage_InitResponse) GetSupportedCodecs() []Codec

func (*StreamingWriteServerMessage_InitResponse) GetTopic 

func (m *StreamingWriteServerMessage_InitResponse) GetTopic() string

func (*StreamingWriteServerMessage_InitResponse) ProtoMessage 

func (*StreamingWriteServerMessage_InitResponse) ProtoMessage()

func (*StreamingWriteServerMessage_InitResponse) Reset 

func (m *StreamingWriteServerMessage_InitResponse) Reset()

func (*StreamingWriteServerMessage_InitResponse) String 

func (m *StreamingWriteServerMessage_InitResponse) String() string

func (*StreamingWriteServerMessage_InitResponse) XXX_DiscardUnknown 

func (m *StreamingWriteServerMessage_InitResponse) XXX_DiscardUnknown()

func (*StreamingWriteServerMessage_InitResponse) XXX_Marshal 

func (m *StreamingWriteServerMessage_InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteServerMessage_InitResponse) XXX_Merge 

func (m *StreamingWriteServerMessage_InitResponse) XXX_Merge(src proto.Message)

func (*StreamingWriteServerMessage_InitResponse) XXX_Size 

func (m *StreamingWriteServerMessage_InitResponse) XXX_Size() int

func (*StreamingWriteServerMessage_InitResponse) XXX_Unmarshal 

func (m *StreamingWriteServerMessage_InitResponse) XXX_Unmarshal(b []byte) error

type StreamingWriteServerMessage_InitResponse_ 

type StreamingWriteServerMessage_InitResponse_ struct {
	InitResponse *StreamingWriteServerMessage_InitResponse `protobuf:"bytes,3,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type StreamingWriteServerMessage_UpdateTokenResponse 

type StreamingWriteServerMessage_UpdateTokenResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingWriteServerMessage_UpdateTokenResponse) Descriptor 

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

func (*StreamingWriteServerMessage_UpdateTokenResponse) ProtoMessage 

func (*StreamingWriteServerMessage_UpdateTokenResponse) ProtoMessage()

func (*StreamingWriteServerMessage_UpdateTokenResponse) Reset 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) Reset()

func (*StreamingWriteServerMessage_UpdateTokenResponse) String 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) String() string

func (*StreamingWriteServerMessage_UpdateTokenResponse) XXX_DiscardUnknown 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) XXX_DiscardUnknown()

func (*StreamingWriteServerMessage_UpdateTokenResponse) XXX_Marshal 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteServerMessage_UpdateTokenResponse) XXX_Merge 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) XXX_Merge(src proto.Message)

func (*StreamingWriteServerMessage_UpdateTokenResponse) XXX_Size 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) XXX_Size() int

func (*StreamingWriteServerMessage_UpdateTokenResponse) XXX_Unmarshal 

func (m *StreamingWriteServerMessage_UpdateTokenResponse) XXX_Unmarshal(b []byte) error

type StreamingWriteServerMessage_UpdateTokenResponse_ 

type StreamingWriteServerMessage_UpdateTokenResponse_ struct {
	UpdateTokenResponse *StreamingWriteServerMessage_UpdateTokenResponse `protobuf:"bytes,5,opt,name=update_token_response,json=updateTokenResponse,proto3,oneof"`
}

type StreamingWriteServerMessage_WriteStatistics 

type StreamingWriteServerMessage_WriteStatistics struct {
	// Time spent in persisting of data.
	PersistDurationMs int64 `protobuf:"varint,1,opt,name=persist_duration_ms,json=persistDurationMs,proto3" json:"persist_duration_ms,omitempty"`
	// Time spent in queue before persisting.
	QueuedInPartitionDurationMs int64 `` /* 149-byte string literal not displayed */
	// Time spent awaiting for partition write quota.
	ThrottledOnPartitionDurationMs int64 `` /* 158-byte string literal not displayed */
	// Time spent awaiting for topic write quota.
	ThrottledOnTopicDurationMs int64    `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

Message with write statistics.

func (*StreamingWriteServerMessage_WriteStatistics) Descriptor 

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

func (*StreamingWriteServerMessage_WriteStatistics) GetPersistDurationMs 

func (m *StreamingWriteServerMessage_WriteStatistics) GetPersistDurationMs() int64

func (*StreamingWriteServerMessage_WriteStatistics) GetQueuedInPartitionDurationMs 

func (m *StreamingWriteServerMessage_WriteStatistics) GetQueuedInPartitionDurationMs() int64

func (*StreamingWriteServerMessage_WriteStatistics) GetThrottledOnPartitionDurationMs 

func (m *StreamingWriteServerMessage_WriteStatistics) GetThrottledOnPartitionDurationMs() int64

func (*StreamingWriteServerMessage_WriteStatistics) GetThrottledOnTopicDurationMs 

func (m *StreamingWriteServerMessage_WriteStatistics) GetThrottledOnTopicDurationMs() int64

func (*StreamingWriteServerMessage_WriteStatistics) ProtoMessage 

func (*StreamingWriteServerMessage_WriteStatistics) ProtoMessage()

func (*StreamingWriteServerMessage_WriteStatistics) Reset 

func (m *StreamingWriteServerMessage_WriteStatistics) Reset()

func (*StreamingWriteServerMessage_WriteStatistics) String 

func (m *StreamingWriteServerMessage_WriteStatistics) String() string

func (*StreamingWriteServerMessage_WriteStatistics) XXX_DiscardUnknown 

func (m *StreamingWriteServerMessage_WriteStatistics) XXX_DiscardUnknown()

func (*StreamingWriteServerMessage_WriteStatistics) XXX_Marshal 

func (m *StreamingWriteServerMessage_WriteStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingWriteServerMessage_WriteStatistics) XXX_Merge 

func (m *StreamingWriteServerMessage_WriteStatistics) XXX_Merge(src proto.Message)

func (*StreamingWriteServerMessage_WriteStatistics) XXX_Size 

func (m *StreamingWriteServerMessage_WriteStatistics) XXX_Size() int

func (*StreamingWriteServerMessage_WriteStatistics) XXX_Unmarshal 

func (m *StreamingWriteServerMessage_WriteStatistics) XXX_Unmarshal(b []byte) error

type TopicSettings 

type TopicSettings struct {
	// How many partitions in topic. Must less than database limit. Default limit - 10.
	PartitionsCount int32 `protobuf:"varint,1,opt,name=partitions_count,json=partitionsCount,proto3" json:"partitions_count,omitempty"`
	// How long data in partition should be stored. Must be greater than 0 and less than limit for this database.  Default limit - 36 hours.
	RetentionPeriodMs int64 `protobuf:"varint,2,opt,name=retention_period_ms,json=retentionPeriodMs,proto3" json:"retention_period_ms,omitempty"`
	// How long last written seqno for message group should be stored. Must be greater then retention_period_ms and less then limit for this database.  Default limit - 16 days.
	MessageGroupSeqnoRetentionPeriodMs int64 `` /* 173-byte string literal not displayed */
	// How many last written seqno for various message groups should be stored per partition. Must be less than limit for this database.  Default limit - 6*10^6 values.
	MaxPartitionMessageGroupsSeqnoStored int64 `` /* 179-byte string literal not displayed */
	// Max format version that is allowed for writers. Must be value from enum FormatVersion.
	// Writes with greater format version are forbiden.
	SupportedFormat TopicSettings_Format `` /* 150-byte string literal not displayed */
	// List of allowed codecs for writers.
	// Writes with codec not from this list are forbiden.
	SupportedCodecs []Codec `` /* 142-byte string literal not displayed */
	// Max storage usage for each topic's partition. Must be less than database limit. Default limit - 130 GB.
	MaxPartitionStorageSize int64 `` /* 135-byte string literal not displayed */
	// Partition write speed in bytes per second. Must be less than database limit. Default limit - 1 MB/s.
	MaxPartitionWriteSpeed int64 `` /* 132-byte string literal not displayed */
	// Burst size for write in partition, in bytes. Must be less than database limit. Default limit - 1 MB.
	MaxPartitionWriteBurst int64 `` /* 132-byte string literal not displayed */
	// Disallows client writes. Used for mirrored topics in federation.
	ClientWriteDisabled bool `protobuf:"varint,8,opt,name=client_write_disabled,json=clientWriteDisabled,proto3" json:"client_write_disabled,omitempty"`
	// List of consumer read rules for this topic.
	ReadRules []*TopicSettings_ReadRule `protobuf:"bytes,9,rep,name=read_rules,json=readRules,proto3" json:"read_rules,omitempty"`
	// User and server attributes of topic. Server attributes starts from "_" and will be validated by server.
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// remote mirror rule for this topic.
	RemoteMirrorRule     *TopicSettings_RemoteMirrorRule `protobuf:"bytes,11,opt,name=remote_mirror_rule,json=remoteMirrorRule,proto3" json:"remote_mirror_rule,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*TopicSettings) Descriptor 

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

func (*TopicSettings) GetAttributes 

func (m *TopicSettings) GetAttributes() map[string]string

func (*TopicSettings) GetClientWriteDisabled 

func (m *TopicSettings) GetClientWriteDisabled() bool

func (*TopicSettings) GetMaxPartitionMessageGroupsSeqnoStored 

func (m *TopicSettings) GetMaxPartitionMessageGroupsSeqnoStored() int64

func (*TopicSettings) GetMaxPartitionStorageSize 

func (m *TopicSettings) GetMaxPartitionStorageSize() int64

func (*TopicSettings) GetMaxPartitionWriteBurst 

func (m *TopicSettings) GetMaxPartitionWriteBurst() int64

func (*TopicSettings) GetMaxPartitionWriteSpeed 

func (m *TopicSettings) GetMaxPartitionWriteSpeed() int64

func (*TopicSettings) GetMessageGroupSeqnoRetentionPeriodMs 

func (m *TopicSettings) GetMessageGroupSeqnoRetentionPeriodMs() int64

func (*TopicSettings) GetPartitionsCount 

func (m *TopicSettings) GetPartitionsCount() int32

func (*TopicSettings) GetReadRules 

func (m *TopicSettings) GetReadRules() []*TopicSettings_ReadRule

func (*TopicSettings) GetRemoteMirrorRule 

func (m *TopicSettings) GetRemoteMirrorRule() *TopicSettings_RemoteMirrorRule

func (*TopicSettings) GetRetentionPeriodMs 

func (m *TopicSettings) GetRetentionPeriodMs() int64

func (*TopicSettings) GetSupportedCodecs 

func (m *TopicSettings) GetSupportedCodecs() []Codec

func (*TopicSettings) GetSupportedFormat 

func (m *TopicSettings) GetSupportedFormat() TopicSettings_Format

func (*TopicSettings) ProtoMessage 

func (*TopicSettings) ProtoMessage()

func (*TopicSettings) Reset 

func (m *TopicSettings) Reset()

func (*TopicSettings) String 

func (m *TopicSettings) String() string

func (*TopicSettings) XXX_DiscardUnknown 

func (m *TopicSettings) XXX_DiscardUnknown()

func (*TopicSettings) XXX_Marshal 

func (m *TopicSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicSettings) XXX_Merge 

func (m *TopicSettings) XXX_Merge(src proto.Message)

func (*TopicSettings) XXX_Size 

func (m *TopicSettings) XXX_Size() int

func (*TopicSettings) XXX_Unmarshal 

func (m *TopicSettings) XXX_Unmarshal(b []byte) error

type TopicSettings_Format 

type TopicSettings_Format int32
const (
	TopicSettings_FORMAT_UNSPECIFIED TopicSettings_Format = 0
	TopicSettings_FORMAT_BASE        TopicSettings_Format = 1
)

func (TopicSettings_Format) EnumDescriptor 

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

func (TopicSettings_Format) String 

func (x TopicSettings_Format) String() string

type TopicSettings_ReadRule 

type TopicSettings_ReadRule struct {
	// For what consumer this read rule is. Must be valid not empty consumer name.
	// Is key for read rules. There could be only one read rule with corresponding consumer name.
	ConsumerName string `protobuf:"bytes,1,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	// Flag that this consumer is important.
	Important bool `protobuf:"varint,2,opt,name=important,proto3" json:"important,omitempty"`
	// All messages with smaller timestamp of write will be skipped.
	StartingMessageTimestampMs int64 `` /* 144-byte string literal not displayed */
	// Max format version that is supported by this consumer.
	// supported_format on topic must not be greater.
	SupportedFormat TopicSettings_Format `` /* 150-byte string literal not displayed */
	// List of supported codecs by this consumer.
	// supported_codecs on topic must be contained inside this list.
	SupportedCodecs []Codec `` /* 142-byte string literal not displayed */
	// Read rule version. Any non-negative integer.
	Version int64 `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	// Client service type.
	ServiceType          string   `protobuf:"bytes,7,opt,name=service_type,json=serviceType,proto3" json:"service_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message for read rules description.

func (*TopicSettings_ReadRule) Descriptor 

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

func (*TopicSettings_ReadRule) GetConsumerName 

func (m *TopicSettings_ReadRule) GetConsumerName() string

func (*TopicSettings_ReadRule) GetImportant 

func (m *TopicSettings_ReadRule) GetImportant() bool

func (*TopicSettings_ReadRule) GetServiceType added in v2.9.6 

func (m *TopicSettings_ReadRule) GetServiceType() string

func (*TopicSettings_ReadRule) GetStartingMessageTimestampMs 

func (m *TopicSettings_ReadRule) GetStartingMessageTimestampMs() int64

func (*TopicSettings_ReadRule) GetSupportedCodecs 

func (m *TopicSettings_ReadRule) GetSupportedCodecs() []Codec

func (*TopicSettings_ReadRule) GetSupportedFormat 

func (m *TopicSettings_ReadRule) GetSupportedFormat() TopicSettings_Format

func (*TopicSettings_ReadRule) GetVersion 

func (m *TopicSettings_ReadRule) GetVersion() int64

func (*TopicSettings_ReadRule) ProtoMessage 

func (*TopicSettings_ReadRule) ProtoMessage()

func (*TopicSettings_ReadRule) Reset 

func (m *TopicSettings_ReadRule) Reset()

func (*TopicSettings_ReadRule) String 

func (m *TopicSettings_ReadRule) String() string

func (*TopicSettings_ReadRule) XXX_DiscardUnknown 

func (m *TopicSettings_ReadRule) XXX_DiscardUnknown()

func (*TopicSettings_ReadRule) XXX_Marshal 

func (m *TopicSettings_ReadRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicSettings_ReadRule) XXX_Merge 

func (m *TopicSettings_ReadRule) XXX_Merge(src proto.Message)

func (*TopicSettings_ReadRule) XXX_Size 

func (m *TopicSettings_ReadRule) XXX_Size() int

func (*TopicSettings_ReadRule) XXX_Unmarshal 

func (m *TopicSettings_ReadRule) XXX_Unmarshal(b []byte) error

type TopicSettings_RemoteMirrorRule 

type TopicSettings_RemoteMirrorRule struct {
	// Source cluster endpoint in format server:port.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Source topic that we want to mirror.
	TopicPath string `protobuf:"bytes,2,opt,name=topic_path,json=topicPath,proto3" json:"topic_path,omitempty"`
	// Source consumer for reading source topic.
	ConsumerName string `protobuf:"bytes,3,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	// Credentials for reading source topic by source consumer.
	Credentials *Credentials `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// All messages with smaller timestamp of write will be skipped.
	StartingMessageTimestampMs int64 `` /* 144-byte string literal not displayed */
	// Database
	Database             string   `protobuf:"bytes,6,opt,name=database,proto3" json:"database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message for remote mirror rule description.

func (*TopicSettings_RemoteMirrorRule) Descriptor 

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

func (*TopicSettings_RemoteMirrorRule) GetConsumerName 

func (m *TopicSettings_RemoteMirrorRule) GetConsumerName() string

func (*TopicSettings_RemoteMirrorRule) GetCredentials 

func (m *TopicSettings_RemoteMirrorRule) GetCredentials() *Credentials

func (*TopicSettings_RemoteMirrorRule) GetDatabase 

func (m *TopicSettings_RemoteMirrorRule) GetDatabase() string

func (*TopicSettings_RemoteMirrorRule) GetEndpoint 

func (m *TopicSettings_RemoteMirrorRule) GetEndpoint() string

func (*TopicSettings_RemoteMirrorRule) GetStartingMessageTimestampMs 

func (m *TopicSettings_RemoteMirrorRule) GetStartingMessageTimestampMs() int64

func (*TopicSettings_RemoteMirrorRule) GetTopicPath 

func (m *TopicSettings_RemoteMirrorRule) GetTopicPath() string

func (*TopicSettings_RemoteMirrorRule) ProtoMessage 

func (*TopicSettings_RemoteMirrorRule) ProtoMessage()

func (*TopicSettings_RemoteMirrorRule) Reset 

func (m *TopicSettings_RemoteMirrorRule) Reset()

func (*TopicSettings_RemoteMirrorRule) String 

func (m *TopicSettings_RemoteMirrorRule) String() string

func (*TopicSettings_RemoteMirrorRule) XXX_DiscardUnknown 

func (m *TopicSettings_RemoteMirrorRule) XXX_DiscardUnknown()

func (*TopicSettings_RemoteMirrorRule) XXX_Marshal 

func (m *TopicSettings_RemoteMirrorRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicSettings_RemoteMirrorRule) XXX_Merge 

func (m *TopicSettings_RemoteMirrorRule) XXX_Merge(src proto.Message)

func (*TopicSettings_RemoteMirrorRule) XXX_Size 

func (m *TopicSettings_RemoteMirrorRule) XXX_Size() int

func (*TopicSettings_RemoteMirrorRule) XXX_Unmarshal 

func (m *TopicSettings_RemoteMirrorRule) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.