rpc

package
v0.0.0-...-5019c65 Latest Latest
Warning

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

 Go to latest Published: May 23, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_TBalancingExt_StickyGroupSize = int32(1)
)

Default values for TBalancingExt fields.

Variables

View Source 
var (
	EWriterFeedback_name = map[int32]string{
		0: "WF_HANDSHAKE",
		1: "WF_SUCCESS",
	}
	EWriterFeedback_value = map[string]int32{
		"WF_HANDSHAKE": 0,
		"WF_SUCCESS":   1,
	}
)

Enum value maps for EWriterFeedback.

View Source 
var (
	// optional NYT.NTracing.NProto.TTracingExt tracing_ext = 106;
	E_TRequestHeader_TracingExt = &file_yt_proto_yt_core_rpc_proto_rpc_proto_extTypes[0]
	// optional NYT.NRpc.NProto.TBalancingExt balancing_ext = 111;
	E_TBalancingExt_BalancingExt = &file_yt_proto_yt_core_rpc_proto_rpc_proto_extTypes[1]
	// optional NYT.NRpc.NProto.TCredentialsExt credentials_ext = 110;
	E_TCredentialsExt_CredentialsExt = &file_yt_proto_yt_core_rpc_proto_rpc_proto_extTypes[2]
)

Extension fields to TRequestHeader.

View Source 
var (
	// optional NYT.NRpc.NProto.THedgingExt hedging_ext = 100;
	E_THedgingExt_HedgingExt = &file_yt_proto_yt_core_rpc_proto_rpc_proto_extTypes[3]
)

Extension fields to TResponseHeader.

View Source 
var File_yt_proto_yt_core_rpc_proto_rpc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EWriterFeedback 

type EWriterFeedback int32
const (
	EWriterFeedback_WF_HANDSHAKE EWriterFeedback = 0
	EWriterFeedback_WF_SUCCESS   EWriterFeedback = 1
)

func (EWriterFeedback) Descriptor 

func (EWriterFeedback) Descriptor() protoreflect.EnumDescriptor

func (EWriterFeedback) Enum 

func (x EWriterFeedback) Enum() *EWriterFeedback

func (EWriterFeedback) EnumDescriptor deprecated 

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

Deprecated: Use EWriterFeedback.Descriptor instead.

func (EWriterFeedback) Number 

func (x EWriterFeedback) Number() protoreflect.EnumNumber

func (EWriterFeedback) String 

func (x EWriterFeedback) String() string

func (EWriterFeedback) Type 

func (EWriterFeedback) Type() protoreflect.EnumType

func (*EWriterFeedback) UnmarshalJSON deprecated 

func (x *EWriterFeedback) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TBalancingExt 

type TBalancingExt struct {
	EnableStickiness       *bool  `protobuf:"varint,1,opt,name=enable_stickiness,json=enableStickiness" json:"enable_stickiness,omitempty"`
	StickyGroupSize        *int32 `protobuf:"varint,2,opt,name=sticky_group_size,json=stickyGroupSize,def=1" json:"sticky_group_size,omitempty"`
	EnableClientStickiness *bool  `protobuf:"varint,3,opt,name=enable_client_stickiness,json=enableClientStickiness" json:"enable_client_stickiness,omitempty"`
	// contains filtered or unexported fields
}

func (*TBalancingExt) Descriptor deprecated 

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

Deprecated: Use TBalancingExt.ProtoReflect.Descriptor instead.

func (*TBalancingExt) GetEnableClientStickiness 

func (x *TBalancingExt) GetEnableClientStickiness() bool

func (*TBalancingExt) GetEnableStickiness 

func (x *TBalancingExt) GetEnableStickiness() bool

func (*TBalancingExt) GetStickyGroupSize 

func (x *TBalancingExt) GetStickyGroupSize() int32

func (*TBalancingExt) ProtoMessage 

func (*TBalancingExt) ProtoMessage()

func (*TBalancingExt) ProtoReflect 

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

func (*TBalancingExt) Reset 

func (x *TBalancingExt) Reset()

func (*TBalancingExt) String 

func (x *TBalancingExt) String() string

type TCredentialsExt 

type TCredentialsExt struct {
	Token         *string `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	SessionId     *string `protobuf:"bytes,4,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	SslSessionId  *string `protobuf:"bytes,5,opt,name=ssl_session_id,json=sslSessionId" json:"ssl_session_id,omitempty"`
	UserTicket    *string `protobuf:"bytes,6,opt,name=user_ticket,json=userTicket" json:"user_ticket,omitempty"`
	ServiceTicket *string `protobuf:"bytes,7,opt,name=service_ticket,json=serviceTicket" json:"service_ticket,omitempty"`
	// contains filtered or unexported fields
}

func (*TCredentialsExt) Descriptor deprecated 

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

Deprecated: Use TCredentialsExt.ProtoReflect.Descriptor instead.

func (*TCredentialsExt) GetServiceTicket 

func (x *TCredentialsExt) GetServiceTicket() string

func (*TCredentialsExt) GetSessionId 

func (x *TCredentialsExt) GetSessionId() string

func (*TCredentialsExt) GetSslSessionId 

func (x *TCredentialsExt) GetSslSessionId() string

func (*TCredentialsExt) GetToken 

func (x *TCredentialsExt) GetToken() string

func (*TCredentialsExt) GetUserTicket 

func (x *TCredentialsExt) GetUserTicket() string

func (*TCredentialsExt) ProtoMessage 

func (*TCredentialsExt) ProtoMessage()

func (*TCredentialsExt) ProtoReflect 

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

func (*TCredentialsExt) Reset 

func (x *TCredentialsExt) Reset()

func (*TCredentialsExt) String 

func (x *TCredentialsExt) String() string

type THedgingExt 

type THedgingExt struct {
	BackupResponded *bool `protobuf:"varint,1,opt,name=backup_responded,json=backupResponded" json:"backup_responded,omitempty"`
	// contains filtered or unexported fields
}

func (*THedgingExt) Descriptor deprecated 

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

Deprecated: Use THedgingExt.ProtoReflect.Descriptor instead.

func (*THedgingExt) GetBackupResponded 

func (x *THedgingExt) GetBackupResponded() bool

func (*THedgingExt) ProtoMessage 

func (*THedgingExt) ProtoMessage()

func (*THedgingExt) ProtoReflect 

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

func (*THedgingExt) Reset 

func (x *THedgingExt) Reset()

func (*THedgingExt) String 

func (x *THedgingExt) String() string

type TReqDiscover 

type TReqDiscover struct {
	ReplyDelay *int64 `protobuf:"varint,1,opt,name=reply_delay,json=replyDelay" json:"reply_delay,omitempty"`
	// contains filtered or unexported fields
}

func (*TReqDiscover) Descriptor deprecated 

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

Deprecated: Use TReqDiscover.ProtoReflect.Descriptor instead.

func (*TReqDiscover) GetReplyDelay 

func (x *TReqDiscover) GetReplyDelay() int64

func (*TReqDiscover) ProtoMessage 

func (*TReqDiscover) ProtoMessage()

func (*TReqDiscover) ProtoReflect 

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

func (*TReqDiscover) Reset 

func (x *TReqDiscover) Reset()

func (*TReqDiscover) String 

func (x *TReqDiscover) String() string

type TRequestCancelationHeader 

type TRequestCancelationHeader struct {
	RequestId *misc.TGuid `protobuf:"bytes,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Service   *string     `protobuf:"bytes,2,req,name=service" json:"service,omitempty"`
	Method    *string     `protobuf:"bytes,3,req,name=method" json:"method,omitempty"`
	RealmId   *misc.TGuid `protobuf:"bytes,4,opt,name=realm_id,json=realmId" json:"realm_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TRequestCancelationHeader) Descriptor deprecated 

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

Deprecated: Use TRequestCancelationHeader.ProtoReflect.Descriptor instead.

func (*TRequestCancelationHeader) GetMethod 

func (x *TRequestCancelationHeader) GetMethod() string

func (*TRequestCancelationHeader) GetRealmId 

func (x *TRequestCancelationHeader) GetRealmId() *misc.TGuid

func (*TRequestCancelationHeader) GetRequestId 

func (x *TRequestCancelationHeader) GetRequestId() *misc.TGuid

func (*TRequestCancelationHeader) GetService 

func (x *TRequestCancelationHeader) GetService() string

func (*TRequestCancelationHeader) ProtoMessage 

func (*TRequestCancelationHeader) ProtoMessage()

func (*TRequestCancelationHeader) ProtoReflect 

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

func (*TRequestCancelationHeader) Reset 

func (x *TRequestCancelationHeader) Reset()

func (*TRequestCancelationHeader) String 

func (x *TRequestCancelationHeader) String() string

type TRequestHeader 

type TRequestHeader struct {
	RequestId                                *misc.TGuid `protobuf:"bytes,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	Service                                  *string     `protobuf:"bytes,2,req,name=service" json:"service,omitempty"`
	Method                                   *string     `protobuf:"bytes,3,req,name=method" json:"method,omitempty"`
	RealmId                                  *misc.TGuid `protobuf:"bytes,8,opt,name=realm_id,json=realmId" json:"realm_id,omitempty"`
	ProtocolVersionMajor                     *int32      `protobuf:"varint,9,opt,name=protocol_version_major,json=protocolVersionMajor" json:"protocol_version_major,omitempty"`
	ProtocolVersionMinor                     *int32      `protobuf:"varint,19,opt,name=protocol_version_minor,json=protocolVersionMinor" json:"protocol_version_minor,omitempty"`
	StartTime                                *int64      `protobuf:"varint,7,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	Retry                                    *bool       `protobuf:"varint,11,opt,name=retry" json:"retry,omitempty"`
	MutationId                               *misc.TGuid `protobuf:"bytes,13,opt,name=mutation_id,json=mutationId" json:"mutation_id,omitempty"`
	Timeout                                  *int64      `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"`
	User                                     *string     `protobuf:"bytes,12,opt,name=user" json:"user,omitempty"`
	UserTag                                  *string     `protobuf:"bytes,25,opt,name=user_tag,json=userTag" json:"user_tag,omitempty"`
	TosLevel                                 *int32      `protobuf:"varint,14,opt,name=tos_level,json=tosLevel" json:"tos_level,omitempty"`
	RequestFormat                            *int32      `protobuf:"varint,15,opt,name=request_format,json=requestFormat" json:"request_format,omitempty"`    // EMessageFormat
	ResponseFormat                           *int32      `protobuf:"varint,16,opt,name=response_format,json=responseFormat" json:"response_format,omitempty"` // EMessageFormat
	Uncancelable                             *bool       `protobuf:"varint,17,opt,name=uncancelable" json:"uncancelable,omitempty"`
	UserAgent                                *string     `protobuf:"bytes,18,opt,name=user_agent,json=userAgent" json:"user_agent,omitempty"`
	LoggingSuppressionTimeout                *int64      `` /* 133-byte string literal not displayed */
	DisableLoggingSuppressionIfRequestFailed *bool       `` /* 184-byte string literal not displayed */
	// COMPAT(kiseloyvp): these are missing when legacy mode is used
	RequestCodec                         *int32                `protobuf:"varint,23,opt,name=request_codec,json=requestCodec" json:"request_codec,omitempty"`                             // ECodec
	ResponseCodec                        *int32                `protobuf:"varint,24,opt,name=response_codec,json=responseCodec" json:"response_codec,omitempty"`                          // ECodec
	ServerAttachmentsStreamingParameters *TStreamingParameters ``                                                                                                                         /* 167-byte string literal not displayed */
	RequestFormatOptions                 []byte                `protobuf:"bytes,34,opt,name=request_format_options,json=requestFormatOptions" json:"request_format_options,omitempty"`    // TYsonString
	ResponseFormatOptions                []byte                `protobuf:"bytes,35,opt,name=response_format_options,json=responseFormatOptions" json:"response_format_options,omitempty"` // TYsonString
	DeclaredClientFeatureIds             []int32               ``                                                                                                                         /* 132-byte string literal not displayed */
	RequiredServerFeatureIds             []int32               ``                                                                                                                         /* 132-byte string literal not displayed */
	LogicalRequestWeight                 *int64                `protobuf:"varint,38,opt,name=logical_request_weight,json=logicalRequestWeight" json:"logical_request_weight,omitempty"`
	// contains filtered or unexported fields
}

func (*TRequestHeader) Descriptor deprecated 

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

Deprecated: Use TRequestHeader.ProtoReflect.Descriptor instead.

func (*TRequestHeader) GetDeclaredClientFeatureIds 

func (x *TRequestHeader) GetDeclaredClientFeatureIds() []int32

func (*TRequestHeader) GetDisableLoggingSuppressionIfRequestFailed 

func (x *TRequestHeader) GetDisableLoggingSuppressionIfRequestFailed() bool

func (*TRequestHeader) GetLoggingSuppressionTimeout 

func (x *TRequestHeader) GetLoggingSuppressionTimeout() int64

func (*TRequestHeader) GetLogicalRequestWeight 

func (x *TRequestHeader) GetLogicalRequestWeight() int64

func (*TRequestHeader) GetMethod 

func (x *TRequestHeader) GetMethod() string

func (*TRequestHeader) GetMutationId 

func (x *TRequestHeader) GetMutationId() *misc.TGuid

func (*TRequestHeader) GetProtocolVersionMajor 

func (x *TRequestHeader) GetProtocolVersionMajor() int32

func (*TRequestHeader) GetProtocolVersionMinor 

func (x *TRequestHeader) GetProtocolVersionMinor() int32

func (*TRequestHeader) GetRealmId 

func (x *TRequestHeader) GetRealmId() *misc.TGuid

func (*TRequestHeader) GetRequestCodec 

func (x *TRequestHeader) GetRequestCodec() int32

func (*TRequestHeader) GetRequestFormat 

func (x *TRequestHeader) GetRequestFormat() int32

func (*TRequestHeader) GetRequestFormatOptions 

func (x *TRequestHeader) GetRequestFormatOptions() []byte

func (*TRequestHeader) GetRequestId 

func (x *TRequestHeader) GetRequestId() *misc.TGuid

func (*TRequestHeader) GetRequiredServerFeatureIds 

func (x *TRequestHeader) GetRequiredServerFeatureIds() []int32

func (*TRequestHeader) GetResponseCodec 

func (x *TRequestHeader) GetResponseCodec() int32

func (*TRequestHeader) GetResponseFormat 

func (x *TRequestHeader) GetResponseFormat() int32

func (*TRequestHeader) GetResponseFormatOptions 

func (x *TRequestHeader) GetResponseFormatOptions() []byte

func (*TRequestHeader) GetRetry 

func (x *TRequestHeader) GetRetry() bool

func (*TRequestHeader) GetServerAttachmentsStreamingParameters 

func (x *TRequestHeader) GetServerAttachmentsStreamingParameters() *TStreamingParameters

func (*TRequestHeader) GetService 

func (x *TRequestHeader) GetService() string

func (*TRequestHeader) GetStartTime 

func (x *TRequestHeader) GetStartTime() int64

func (*TRequestHeader) GetTimeout 

func (x *TRequestHeader) GetTimeout() int64

func (*TRequestHeader) GetTosLevel 

func (x *TRequestHeader) GetTosLevel() int32

func (*TRequestHeader) GetUncancelable 

func (x *TRequestHeader) GetUncancelable() bool

func (*TRequestHeader) GetUser 

func (x *TRequestHeader) GetUser() string

func (*TRequestHeader) GetUserAgent 

func (x *TRequestHeader) GetUserAgent() string

func (*TRequestHeader) GetUserTag 

func (x *TRequestHeader) GetUserTag() string

func (*TRequestHeader) ProtoMessage 

func (*TRequestHeader) ProtoMessage()

func (*TRequestHeader) ProtoReflect 

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

func (*TRequestHeader) Reset 

func (x *TRequestHeader) Reset()

func (*TRequestHeader) String 

func (x *TRequestHeader) String() string

type TResponseHeader 

type TResponseHeader struct {
	RequestId *misc.TGuid `protobuf:"bytes,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	// If omitted then OK is assumed.
	Error  *misc.TError `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Format *int32       `protobuf:"varint,3,opt,name=format" json:"format,omitempty"` // EMessageFormat
	// COMPAT(kiseloyvp): this is missing when legacy mode is used
	Codec *int32 `protobuf:"varint,6,opt,name=codec" json:"codec,omitempty"` // ECodec
	// contains filtered or unexported fields
}

func (*TResponseHeader) Descriptor deprecated 

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

Deprecated: Use TResponseHeader.ProtoReflect.Descriptor instead.

func (*TResponseHeader) GetCodec 

func (x *TResponseHeader) GetCodec() int32

func (*TResponseHeader) GetError 

func (x *TResponseHeader) GetError() *misc.TError

func (*TResponseHeader) GetFormat 

func (x *TResponseHeader) GetFormat() int32

func (*TResponseHeader) GetRequestId 

func (x *TResponseHeader) GetRequestId() *misc.TGuid

func (*TResponseHeader) ProtoMessage 

func (*TResponseHeader) ProtoMessage()

func (*TResponseHeader) ProtoReflect 

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

func (*TResponseHeader) Reset 

func (x *TResponseHeader) Reset()

func (*TResponseHeader) String 

func (x *TResponseHeader) String() string

type TRspDiscover 

type TRspDiscover struct {
	Up                 *bool    `protobuf:"varint,1,req,name=up" json:"up,omitempty"`
	SuggestedAddresses []string `protobuf:"bytes,2,rep,name=suggested_addresses,json=suggestedAddresses" json:"suggested_addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*TRspDiscover) Descriptor deprecated 

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

Deprecated: Use TRspDiscover.ProtoReflect.Descriptor instead.

func (*TRspDiscover) GetSuggestedAddresses 

func (x *TRspDiscover) GetSuggestedAddresses() []string

func (*TRspDiscover) GetUp 

func (x *TRspDiscover) GetUp() bool

func (*TRspDiscover) ProtoMessage 

func (*TRspDiscover) ProtoMessage()

func (*TRspDiscover) ProtoReflect 

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

func (*TRspDiscover) Reset 

func (x *TRspDiscover) Reset()

func (*TRspDiscover) String 

func (x *TRspDiscover) String() string

type TStreamingFeedbackHeader 

type TStreamingFeedbackHeader struct {
	RequestId    *misc.TGuid `protobuf:"bytes,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Service      *string     `protobuf:"bytes,2,req,name=service" json:"service,omitempty"`
	Method       *string     `protobuf:"bytes,3,req,name=method" json:"method,omitempty"`
	RealmId      *misc.TGuid `protobuf:"bytes,4,opt,name=realm_id,json=realmId" json:"realm_id,omitempty"`
	ReadPosition *int64      `protobuf:"varint,5,req,name=read_position,json=readPosition" json:"read_position,omitempty"`
	// contains filtered or unexported fields
}

func (*TStreamingFeedbackHeader) Descriptor deprecated 

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

Deprecated: Use TStreamingFeedbackHeader.ProtoReflect.Descriptor instead.

func (*TStreamingFeedbackHeader) GetMethod 

func (x *TStreamingFeedbackHeader) GetMethod() string

func (*TStreamingFeedbackHeader) GetReadPosition 

func (x *TStreamingFeedbackHeader) GetReadPosition() int64

func (*TStreamingFeedbackHeader) GetRealmId 

func (x *TStreamingFeedbackHeader) GetRealmId() *misc.TGuid

func (*TStreamingFeedbackHeader) GetRequestId 

func (x *TStreamingFeedbackHeader) GetRequestId() *misc.TGuid

func (*TStreamingFeedbackHeader) GetService 

func (x *TStreamingFeedbackHeader) GetService() string

func (*TStreamingFeedbackHeader) ProtoMessage 

func (*TStreamingFeedbackHeader) ProtoMessage()

func (*TStreamingFeedbackHeader) ProtoReflect 

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

func (*TStreamingFeedbackHeader) Reset 

func (x *TStreamingFeedbackHeader) Reset()

func (*TStreamingFeedbackHeader) String 

func (x *TStreamingFeedbackHeader) String() string

type TStreamingParameters 

type TStreamingParameters struct {
	WindowSize   *int64 `protobuf:"varint,1,opt,name=window_size,json=windowSize" json:"window_size,omitempty"`
	ReadTimeout  *int64 `protobuf:"varint,2,opt,name=read_timeout,json=readTimeout" json:"read_timeout,omitempty"`
	WriteTimeout *int64 `protobuf:"varint,3,opt,name=write_timeout,json=writeTimeout" json:"write_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*TStreamingParameters) Descriptor deprecated 

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

Deprecated: Use TStreamingParameters.ProtoReflect.Descriptor instead.

func (*TStreamingParameters) GetReadTimeout 

func (x *TStreamingParameters) GetReadTimeout() int64

func (*TStreamingParameters) GetWindowSize 

func (x *TStreamingParameters) GetWindowSize() int64

func (*TStreamingParameters) GetWriteTimeout 

func (x *TStreamingParameters) GetWriteTimeout() int64

func (*TStreamingParameters) ProtoMessage 

func (*TStreamingParameters) ProtoMessage()

func (*TStreamingParameters) ProtoReflect 

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

func (*TStreamingParameters) Reset 

func (x *TStreamingParameters) Reset()

func (*TStreamingParameters) String 

func (x *TStreamingParameters) String() string

type TStreamingPayloadHeader 

type TStreamingPayloadHeader struct {
	RequestId      *misc.TGuid `protobuf:"bytes,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Service        *string     `protobuf:"bytes,2,req,name=service" json:"service,omitempty"`
	Method         *string     `protobuf:"bytes,3,req,name=method" json:"method,omitempty"`
	RealmId        *misc.TGuid `protobuf:"bytes,4,opt,name=realm_id,json=realmId" json:"realm_id,omitempty"`
	SequenceNumber *int32      `protobuf:"varint,5,req,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	Codec          *int32      `protobuf:"varint,6,opt,name=codec" json:"codec,omitempty"` // ECodec
	// contains filtered or unexported fields
}

func (*TStreamingPayloadHeader) Descriptor deprecated 

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

Deprecated: Use TStreamingPayloadHeader.ProtoReflect.Descriptor instead.

func (*TStreamingPayloadHeader) GetCodec 

func (x *TStreamingPayloadHeader) GetCodec() int32

func (*TStreamingPayloadHeader) GetMethod 

func (x *TStreamingPayloadHeader) GetMethod() string

func (*TStreamingPayloadHeader) GetRealmId 

func (x *TStreamingPayloadHeader) GetRealmId() *misc.TGuid

func (*TStreamingPayloadHeader) GetRequestId 

func (x *TStreamingPayloadHeader) GetRequestId() *misc.TGuid

func (*TStreamingPayloadHeader) GetSequenceNumber 

func (x *TStreamingPayloadHeader) GetSequenceNumber() int32

func (*TStreamingPayloadHeader) GetService 

func (x *TStreamingPayloadHeader) GetService() string

func (*TStreamingPayloadHeader) ProtoMessage 

func (*TStreamingPayloadHeader) ProtoMessage()

func (*TStreamingPayloadHeader) ProtoReflect 

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

func (*TStreamingPayloadHeader) Reset 

func (x *TStreamingPayloadHeader) Reset()

func (*TStreamingPayloadHeader) String 

func (x *TStreamingPayloadHeader) String() string

type TWriterFeedback 

type TWriterFeedback struct {
	Feedback *EWriterFeedback `protobuf:"varint,1,req,name=feedback,enum=NYT.NRpc.NProto.EWriterFeedback" json:"feedback,omitempty"`
	// contains filtered or unexported fields
}

func (*TWriterFeedback) Descriptor deprecated 

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

Deprecated: Use TWriterFeedback.ProtoReflect.Descriptor instead.

func (*TWriterFeedback) GetFeedback 

func (x *TWriterFeedback) GetFeedback() EWriterFeedback

func (*TWriterFeedback) ProtoMessage 

func (*TWriterFeedback) ProtoMessage()

func (*TWriterFeedback) ProtoReflect 

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

func (*TWriterFeedback) Reset 

func (x *TWriterFeedback) Reset()

func (*TWriterFeedback) String 

func (x *TWriterFeedback) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.