protobuf

Documentation

Index

• Variables
• func IsProtobufCodec(c remote.PayloadCodec) bool
• func NewProtobufCodec() remote.PayloadCodec
• type ErrorProto
  • func (*ErrorProto) Descriptor() ([]byte, []int)
  • func (x *ErrorProto) GetMessage() string
  • func (x *ErrorProto) GetTypeID() int32
  • func (*ErrorProto) ProtoMessage()
  • func (x *ErrorProto) ProtoReflect() protoreflect.Message
  • func (x *ErrorProto) Reset()
  • func (x *ErrorProto) String() string
• type MessageReaderWithMethodWithContext
• type MessageWriterWithContext
• type MockReq
  • func (*MockReq) Descriptor() ([]byte, []int)
  • func (x *MockReq) GetMsg() string
  • func (x *MockReq) GetStrList() []string
  • func (x *MockReq) GetStrMap() map[string]string
  • func (*MockReq) ProtoMessage()
  • func (x *MockReq) ProtoReflect() protoreflect.Message
  • func (x *MockReq) Reset()
  • func (x *MockReq) String() string
• type PBError
  • func NewPbError(typeID int32, message string) PBError
• type ProtobufMsgCodec

Variables

var File_kitex_pkg_remote_codec_protobuf_error_proto protoreflect.FileDescriptor

var File_test_proto protoreflect.FileDescriptor

Functions

func IsProtobufCodec

func IsProtobufCodec(c remote.PayloadCodec) bool

IsProtobufCodec checks if the codec is protobufCodec

func NewProtobufCodec

func NewProtobufCodec() remote.PayloadCodec

NewProtobufCodec ...

Types

type ErrorProto

type ErrorProto struct {
	TypeID  int32  `protobuf:"varint,1,opt,name=TypeID,proto3" json:"TypeID,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

Messages used for transporting error between server and client.

func (*ErrorProto) Descriptor

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

Deprecated: Use ErrorProto.ProtoReflect.Descriptor instead.

func (*ErrorProto) GetMessage

func (x *ErrorProto) GetMessage() string

func (*ErrorProto) GetTypeID

func (x *ErrorProto) GetTypeID() int32

func (*ErrorProto) ProtoMessage

func (*ErrorProto) ProtoMessage()

func (*ErrorProto) ProtoReflect

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

func (*ErrorProto) Reset

func (x *ErrorProto) Reset()

func (*ErrorProto) String

func (x *ErrorProto) String() string

type MessageReaderWithMethodWithContext

type MessageReaderWithMethodWithContext interface {
	ReadPb(ctx context.Context, method string, in []byte) error
}

MessageReaderWithMethodWithContext read from ActualMsgBuf with method

type MessageWriterWithContext

type MessageWriterWithContext interface {
	WritePb(ctx context.Context, method string) (interface{}, error)
}

MessageWriterWithContext writes to output bytebuffer

type MockReq

type MockReq struct {
	Msg     string            `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	StrMap  map[string]string `` /* 153-byte string literal not displayed */
	StrList []string          `protobuf:"bytes,3,rep,name=strList,proto3" json:"strList,omitempty"`
	// contains filtered or unexported fields
}

func (*MockReq) Descriptor

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

Deprecated: Use MockReq.ProtoReflect.Descriptor instead.

func (*MockReq) GetMsg

func (x *MockReq) GetMsg() string

func (*MockReq) GetStrList

func (x *MockReq) GetStrList() []string

func (*MockReq) GetStrMap

func (x *MockReq) GetStrMap() map[string]string

func (*MockReq) ProtoMessage

func (*MockReq) ProtoMessage()

func (*MockReq) ProtoReflect

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

func (*MockReq) Reset

func (x *MockReq) Reset()

func (*MockReq) String

func (x *MockReq) String() string

type PBError

type PBError interface {
	error
	TypeID() int32
	Marshal(out []byte) ([]byte, error)
	Unmarshal(in []byte) error
}

func NewPbError

func NewPbError(typeID int32, message string) PBError

type ProtobufMsgCodec

type ProtobufMsgCodec interface {
	Marshal(out []byte) ([]byte, error)
	Unmarshal(in []byte) error
}