proto

Documentation

Index

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

Types

type Message

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

func NewMessage

func NewMessage(descriptor MessageDescriptor) Message

type MessageDescriptor

type MessageDescriptor = *desc.MessageDescriptor

type MessageReader

type MessageReader interface {
	Read(ctx context.Context, method string, 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{}) (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, isClient bool, convOpts *conv.Options) (*ReadJSON, error)

NewReadJSON build ReadJSON according to ServiceDescriptor

func (*ReadJSON) Read

func (m *ReadJSON) Read(ctx context.Context, method string, 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, method string, isClient bool, convOpts *conv.Options) (*WriteJSON, error)

NewWriteJSON build WriteJSON according to ServiceDescriptor

func (*WriteJSON) Write

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

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