proto

Documentation

Index

• type JSONReaderWriter
  • func NewJsonReaderWriter(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *JSONReaderWriter
• type Message
  • func NewMessage(descriptor MessageDescriptor) Message
• type MessageDescriptor
• type MessageReader
• type MessageWriter
• type ReadJSON
  • func NewReadJSON(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *ReadJSON
  • func (m *ReadJSON) Read(ctx context.Context, method string, isClient bool, actualMsgBuf []byte) (interface{}, error)
• type ServiceDescriptor
• type WriteJSON
  • func NewWriteJSON(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *WriteJSON
  • func (m *WriteJSON) Write(ctx context.Context, msg interface{}, method string, isClient bool) (interface{}, error)

Types

type JSONReaderWriter

type JSONReaderWriter struct {
	*ReadJSON
	*WriteJSON
}

func NewJsonReaderWriter

func NewJsonReaderWriter(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *JSONReaderWriter

type Message

type Message interface {
	Marshal() ([]byte, error)
	TryGetFieldByNumber(fieldNumber int) (interface{}, error)
	TrySetFieldByNumber(fieldNumber int, val interface{}) error
}

Deprecated: please use github.com/jhump/protoreflect/dynamic Message instead

func NewMessage

func NewMessage(descriptor MessageDescriptor) Message

Deprecated: please use github.com/jhump/protoreflect/dynamic NewMessage instead

type MessageDescriptor

type MessageDescriptor = *desc.MessageDescriptor

type MessageReader

type MessageReader interface {
	Read(ctx context.Context, method string, isClient bool, actualMsgBuf []byte) (interface{}, error)
}

MessageReader read from ActualMsgBuf with method and returns a string

type MessageWriter

type MessageWriter interface {
	Write(ctx context.Context, msg interface{}, method string, isClient bool) (interface{}, error)
}

MessageWriter writes to a converts json to protobufs wireformat and returns an output bytebuffer

type ReadJSON

type ReadJSON struct {
	// contains filtered or unexported fields
}

ReadJSON implement of MessageReaderWithMethod

func NewReadJSON

func NewReadJSON(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *ReadJSON

NewReadJSON build ReadJSON according to ServiceDescriptor

func (*ReadJSON) Read

func (m *ReadJSON) Read(ctx context.Context, method string, isClient bool, actualMsgBuf []byte) (interface{}, error)

Read reads data from actualMsgBuf and convert to json string

type ServiceDescriptor

type ServiceDescriptor = *desc.ServiceDescriptor

type WriteJSON

type WriteJSON struct {
	// contains filtered or unexported fields
}

WriteJSON implement of MessageWriter

func NewWriteJSON

func NewWriteJSON(svc *dproto.ServiceDescriptor, convOpts *conv.Options) *WriteJSON

NewWriteJSON build WriteJSON according to ServiceDescriptor

func (*WriteJSON) Write

func (m *WriteJSON) Write(ctx context.Context, msg interface{}, method string, isClient bool) (interface{}, error)

Write converts msg to protobuf wire format and returns an output bytebuffer