internalapi

Documentation

Overview

Deprecated: file was moved to ydb package To use it, rename the import to github.com/yandex-cloud/ydb-go-sdk/v2

Deprecated: file was moved to ydb package To use it, rename the import to github.com/yandex-cloud/ydb-go-sdk/v2

Index

• type NoOpResponse
• type OpResponse
• type Operation
  • func Wrap(method string, req, res proto.Message) Operation
  • func WrapWithResponse(method string, req proto.Message, resp Response) Operation
• type Response
  • func Unwrap(op Operation) (method string, req, res proto.Message, resp Response)
  • func WrapNoOpResponse(resp NoOpResponse) Response
  • func WrapOpResponse(resp OpResponse) Response
• type StreamOperation
  • func WrapStreamOperation(method string, req proto.Message, resp StreamOperationResponse, p func(error)) StreamOperation
• type StreamOperationResponse
  • func UnwrapStreamOperation(op StreamOperation) (method string, req proto.Message, resp StreamOperationResponse, ...)

Types

type NoOpResponse

type NoOpResponse = internal.NoOpResponse

type OpResponse

type OpResponse = internal.OpResponse

type Operation

type Operation = internal.Operation

func Wrap

func Wrap(method string, req, res proto.Message) Operation

func WrapWithResponse

func WrapWithResponse(method string, req proto.Message, resp Response) Operation

type Response

type Response = internal.Response

func Unwrap

func Unwrap(op Operation) (method string, req, res proto.Message, resp Response)

func WrapNoOpResponse

func WrapNoOpResponse(resp NoOpResponse) Response

func WrapOpResponse

func WrapOpResponse(resp OpResponse) Response

type StreamOperation

type StreamOperation = internal.StreamOperation

func WrapStreamOperation

func WrapStreamOperation(
	method string, req proto.Message,
	resp StreamOperationResponse,
	p func(error),
) StreamOperation

type StreamOperationResponse

type StreamOperationResponse = internal.StreamOperationResponse

func UnwrapStreamOperation

func UnwrapStreamOperation(op StreamOperation) (
	method string, req proto.Message,
	resp StreamOperationResponse,
	processor func(error),
)