marshaler

Documentation

Overview

Package marshaler is a generated protocol buffer package.

It is generated from these files:

item.proto

It has these top-level messages:

RawItemSet
ItemSet
Item
Attribute

Index

• Variables
• type Attribute
  • func (*Attribute) Descriptor() ([]byte, []int)
  • func (m *Attribute) GetName() string
  • func (m *Attribute) GetValue() string
  • func (m *Attribute) Marshal() (dAtA []byte, err error)
  • func (m *Attribute) MarshalTo(dAtA []byte) (int, error)
  • func (*Attribute) ProtoMessage()
  • func (m *Attribute) Reset()
  • func (m *Attribute) Size() (n int)
  • func (m *Attribute) String() string
  • func (m *Attribute) Unmarshal(dAtA []byte) error
• type FileRetriever
• type Item
  • func (*Item) Descriptor() ([]byte, []int)
  • func (m *Item) GetAttributes() []*Attribute
  • func (m *Item) GetId() int32
  • func (m *Item) GetName() string
  • func (m *Item) Marshal() (dAtA []byte, err error)
  • func (m *Item) MarshalTo(dAtA []byte) (int, error)
  • func (*Item) ProtoMessage()
  • func (m *Item) Reset()
  • func (m *Item) Size() (n int)
  • func (m *Item) String() string
  • func (m *Item) Unmarshal(dAtA []byte) error
• type ItemSet
  • func (*ItemSet) Descriptor() ([]byte, []int)
  • func (m *ItemSet) GetItems() []*Item
  • func (m *ItemSet) Marshal() (dAtA []byte, err error)
  • func (m *ItemSet) MarshalTo(dAtA []byte) (int, error)
  • func (*ItemSet) ProtoMessage()
  • func (m *ItemSet) Reset()
  • func (m *ItemSet) Size() (n int)
  • func (m *ItemSet) String() string
  • func (m *ItemSet) Unmarshal(dAtA []byte) error
• type Marshaler
  • func (m Marshaler) Run(inputTopic, outputTopic string) error
• type RawItemSet
  • func (*RawItemSet) Descriptor() ([]byte, []int)
  • func (m *RawItemSet) GetUrl() string
  • func (m *RawItemSet) Marshal() (dAtA []byte, err error)
  • func (m *RawItemSet) MarshalTo(dAtA []byte) (int, error)
  • func (*RawItemSet) ProtoMessage()
  • func (m *RawItemSet) Reset()
  • func (m *RawItemSet) Size() (n int)
  • func (m *RawItemSet) String() string
  • func (m *RawItemSet) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthItem = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowItem   = fmt.Errorf("proto: integer overflow")
)

Types

type Attribute

type Attribute struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Attribute) Descriptor

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

func (*Attribute) GetName

func (m *Attribute) GetName() string

func (*Attribute) GetValue

func (m *Attribute) GetValue() string

func (*Attribute) Marshal

func (m *Attribute) Marshal() (dAtA []byte, err error)

func (*Attribute) MarshalTo

func (m *Attribute) MarshalTo(dAtA []byte) (int, error)

func (*Attribute) ProtoMessage

func (*Attribute) ProtoMessage()

func (*Attribute) Reset

func (m *Attribute) Reset()

func (*Attribute) Size

func (m *Attribute) Size() (n int)

func (*Attribute) String

func (m *Attribute) String() string

func (*Attribute) Unmarshal

func (m *Attribute) Unmarshal(dAtA []byte) error

type FileRetriever

type FileRetriever interface {
	Get(url string) (io.Reader, error)
}

type Item

type Item struct {
	Id         int32        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Attributes []*Attribute `protobuf:"bytes,3,rep,name=attributes" json:"attributes,omitempty"`
}

func (*Item) Descriptor

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

func (*Item) GetAttributes

func (m *Item) GetAttributes() []*Attribute

func (*Item) GetId

func (m *Item) GetId() int32

func (*Item) GetName

func (m *Item) GetName() string

func (*Item) Marshal

func (m *Item) Marshal() (dAtA []byte, err error)

func (*Item) MarshalTo

func (m *Item) MarshalTo(dAtA []byte) (int, error)

func (*Item) ProtoMessage

func (*Item) ProtoMessage()

func (*Item) Reset

func (m *Item) Reset()

func (*Item) Size

func (m *Item) Size() (n int)

func (*Item) String

func (m *Item) String() string

func (*Item) Unmarshal

func (m *Item) Unmarshal(dAtA []byte) error

type ItemSet

type ItemSet struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items" json:"items,omitempty"`
}

func (*ItemSet) Descriptor

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

func (*ItemSet) GetItems

func (m *ItemSet) GetItems() []*Item

func (*ItemSet) Marshal

func (m *ItemSet) Marshal() (dAtA []byte, err error)

func (*ItemSet) MarshalTo

func (m *ItemSet) MarshalTo(dAtA []byte) (int, error)

func (*ItemSet) ProtoMessage

func (*ItemSet) ProtoMessage()

func (*ItemSet) Reset

func (m *ItemSet) Reset()

func (*ItemSet) Size

func (m *ItemSet) Size() (n int)

func (*ItemSet) String

func (m *ItemSet) String() string

func (*ItemSet) Unmarshal

func (m *ItemSet) Unmarshal(dAtA []byte) error

type Marshaler

type Marshaler struct {
	Consumer      sarama.Consumer
	Producer      sarama.SyncProducer
	OffsetManager sarama.OffsetManager
	FileStorage   FileRetriever
	Logger        log.Logger
}

func (Marshaler) Run

func (m Marshaler) Run(inputTopic, outputTopic string) error

type RawItemSet

type RawItemSet struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
}

func (*RawItemSet) Descriptor

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

func (*RawItemSet) GetUrl

func (m *RawItemSet) GetUrl() string

func (*RawItemSet) Marshal

func (m *RawItemSet) Marshal() (dAtA []byte, err error)

func (*RawItemSet) MarshalTo

func (m *RawItemSet) MarshalTo(dAtA []byte) (int, error)

func (*RawItemSet) ProtoMessage

func (*RawItemSet) ProtoMessage()

func (*RawItemSet) Reset

func (m *RawItemSet) Reset()

func (*RawItemSet) Size

func (m *RawItemSet) Size() (n int)

func (*RawItemSet) String

func (m *RawItemSet) String() string

func (*RawItemSet) Unmarshal

func (m *RawItemSet) Unmarshal(dAtA []byte) error