proto

Documentation

Index

• func Encoder(m *dynamic.Message) sarama.Encoder
• func Unmarshal(b []byte, md *desc.MessageDescriptor) (*dynamic.Message, error)
• type Proto
  • func NewProto(filenames []string, importPaths ...string) (p *Proto, err error)
  • func (p *Proto) FindMessage(name string) (*desc.MessageDescriptor, error)

Functions

func Encoder

func Encoder(m *dynamic.Message) sarama.Encoder

Encoder returns sarama.Encoder for protobuf.

func Unmarshal

func Unmarshal(b []byte, md *desc.MessageDescriptor) (*dynamic.Message, error)

Types

type Proto

type Proto struct {
	ImportPaths []string
	// contains filtered or unexported fields
}

func NewProto

func NewProto(filenames []string, importPaths ...string) (p *Proto, err error)

NewProto creates a new instance of Proto. May return a Proto or open/parse error.

func (*Proto) FindMessage

func (p *Proto) FindMessage(name string) (*desc.MessageDescriptor, error)

FindMessage searches for message with given name.