Documentation ¶
Index ¶
- Constants
- func NewContext(brokers *[]string, cfg *sarama.Config) context
- type CatalogMessages
- func (*CatalogMessages) Descriptor() ([]byte, []int)
- func (m *CatalogMessages) GetCatalogMessage() isCatalogMessages_CatalogMessage
- func (m *CatalogMessages) GetProduct() *Product
- func (*CatalogMessages) ProtoMessage()
- func (m *CatalogMessages) Reset()
- func (m *CatalogMessages) String() string
- func (m *CatalogMessages) XXX_DiscardUnknown()
- func (m *CatalogMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CatalogMessages) XXX_Merge(src proto.Message)
- func (*CatalogMessages) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *CatalogMessages) XXX_Size() int
- func (m *CatalogMessages) XXX_Unmarshal(b []byte) error
- type CatalogMessages_Product
- type CatalogPage
- func (*CatalogPage) Descriptor() ([]byte, []int)
- func (m *CatalogPage) GetCurrentPage() int64
- func (m *CatalogPage) GetFiltering() string
- func (m *CatalogPage) GetItemsPerPage() int64
- func (m *CatalogPage) GetProducts() []*Product
- func (m *CatalogPage) GetSetPageTo() int64
- func (m *CatalogPage) GetSorting() string
- func (m *CatalogPage) GetTotalItems() int64
- func (m *CatalogPage) GetTotalPages() int64
- func (*CatalogPage) ProtoMessage()
- func (m *CatalogPage) Reset()
- func (m *CatalogPage) String() string
- func (m *CatalogPage) XXX_DiscardUnknown()
- func (m *CatalogPage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CatalogPage) XXX_Merge(src proto.Message)
- func (m *CatalogPage) XXX_Size() int
- func (m *CatalogPage) XXX_Unmarshal(b []byte) error
- type Product
- func (*Product) Descriptor() ([]byte, []int)
- func (m *Product) GetCategory() string
- func (m *Product) GetDescription() string
- func (m *Product) GetDisabled() bool
- func (m *Product) GetId() string
- func (m *Product) GetLargeImageURL() string
- func (m *Product) GetLongtext() string
- func (m *Product) GetPrice() int64
- func (m *Product) GetSmallImageURL() string
- func (m *Product) GetTitle() string
- func (*Product) ProtoMessage()
- func (m *Product) Reset()
- func (m *Product) String() string
- func (m *Product) XXX_DiscardUnknown()
- func (m *Product) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Product) XXX_Merge(src proto.Message)
- func (m *Product) XXX_Size() int
- func (m *Product) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const ( Topic = "catalog" Partition = 0 )
Variables ¶
This section is empty.
Functions ¶
func NewContext ¶
Types ¶
type CatalogMessages ¶
type CatalogMessages struct { // Types that are valid to be assigned to CatalogMessage: // *CatalogMessages_Product CatalogMessage isCatalogMessages_CatalogMessage `protobuf_oneof:"catalogMessage"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CatalogMessages) Descriptor ¶
func (*CatalogMessages) Descriptor() ([]byte, []int)
func (*CatalogMessages) GetCatalogMessage ¶
func (m *CatalogMessages) GetCatalogMessage() isCatalogMessages_CatalogMessage
func (*CatalogMessages) GetProduct ¶
func (m *CatalogMessages) GetProduct() *Product
func (*CatalogMessages) ProtoMessage ¶
func (*CatalogMessages) ProtoMessage()
func (*CatalogMessages) Reset ¶
func (m *CatalogMessages) Reset()
func (*CatalogMessages) String ¶
func (m *CatalogMessages) String() string
func (*CatalogMessages) XXX_DiscardUnknown ¶
func (m *CatalogMessages) XXX_DiscardUnknown()
func (*CatalogMessages) XXX_Marshal ¶
func (m *CatalogMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CatalogMessages) XXX_Merge ¶
func (dst *CatalogMessages) XXX_Merge(src proto.Message)
func (*CatalogMessages) XXX_OneofFuncs ¶
func (*CatalogMessages) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*CatalogMessages) XXX_Size ¶
func (m *CatalogMessages) XXX_Size() int
func (*CatalogMessages) XXX_Unmarshal ¶
func (m *CatalogMessages) XXX_Unmarshal(b []byte) error
type CatalogMessages_Product ¶
type CatalogMessages_Product struct {
Product *Product `protobuf:"bytes,1,opt,name=product,proto3,oneof"`
}
type CatalogPage ¶
type CatalogPage struct { Products []*Product `protobuf:"bytes,1,rep,name=products,proto3" json:"products,omitempty"` TotalItems int64 `protobuf:"varint,2,opt,name=totalItems,proto3" json:"totalItems,omitempty"` TotalPages int64 `protobuf:"varint,3,opt,name=totalPages,proto3" json:"totalPages,omitempty"` CurrentPage int64 `protobuf:"varint,4,opt,name=currentPage,proto3" json:"currentPage,omitempty"` SetPageTo int64 `protobuf:"varint,5,opt,name=setPageTo,proto3" json:"setPageTo,omitempty"` Sorting string `protobuf:"bytes,6,opt,name=sorting,proto3" json:"sorting,omitempty"` Filtering string `protobuf:"bytes,7,opt,name=filtering,proto3" json:"filtering,omitempty"` ItemsPerPage int64 `protobuf:"varint,8,opt,name=itemsPerPage,proto3" json:"itemsPerPage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CatalogPage) Descriptor ¶
func (*CatalogPage) Descriptor() ([]byte, []int)
func (*CatalogPage) GetCurrentPage ¶
func (m *CatalogPage) GetCurrentPage() int64
func (*CatalogPage) GetFiltering ¶
func (m *CatalogPage) GetFiltering() string
func (*CatalogPage) GetItemsPerPage ¶
func (m *CatalogPage) GetItemsPerPage() int64
func (*CatalogPage) GetProducts ¶
func (m *CatalogPage) GetProducts() []*Product
func (*CatalogPage) GetSetPageTo ¶
func (m *CatalogPage) GetSetPageTo() int64
func (*CatalogPage) GetSorting ¶
func (m *CatalogPage) GetSorting() string
func (*CatalogPage) GetTotalItems ¶
func (m *CatalogPage) GetTotalItems() int64
func (*CatalogPage) GetTotalPages ¶
func (m *CatalogPage) GetTotalPages() int64
func (*CatalogPage) ProtoMessage ¶
func (*CatalogPage) ProtoMessage()
func (*CatalogPage) Reset ¶
func (m *CatalogPage) Reset()
func (*CatalogPage) String ¶
func (m *CatalogPage) String() string
func (*CatalogPage) XXX_DiscardUnknown ¶
func (m *CatalogPage) XXX_DiscardUnknown()
func (*CatalogPage) XXX_Marshal ¶
func (m *CatalogPage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CatalogPage) XXX_Merge ¶
func (dst *CatalogPage) XXX_Merge(src proto.Message)
func (*CatalogPage) XXX_Size ¶
func (m *CatalogPage) XXX_Size() int
func (*CatalogPage) XXX_Unmarshal ¶
func (m *CatalogPage) XXX_Unmarshal(b []byte) error
type Product ¶
type Product struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Price int64 `protobuf:"varint,2,opt,name=price,proto3" json:"price,omitempty"` Title string `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Longtext string `protobuf:"bytes,5,opt,name=longtext,proto3" json:"longtext,omitempty"` Category string `protobuf:"bytes,6,opt,name=category,proto3" json:"category,omitempty"` SmallImageURL string `protobuf:"bytes,7,opt,name=smallImageURL,proto3" json:"smallImageURL,omitempty"` LargeImageURL string `protobuf:"bytes,8,opt,name=largeImageURL,proto3" json:"largeImageURL,omitempty"` Disabled bool `protobuf:"varint,9,opt,name=disabled,proto3" json:"disabled,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Product) Descriptor ¶
func (*Product) GetCategory ¶
func (*Product) GetDescription ¶
func (*Product) GetDisabled ¶
func (*Product) GetLargeImageURL ¶
func (*Product) GetLongtext ¶
func (*Product) GetSmallImageURL ¶
func (*Product) ProtoMessage ¶
func (*Product) ProtoMessage()
func (*Product) XXX_DiscardUnknown ¶
func (m *Product) XXX_DiscardUnknown()
func (*Product) XXX_Marshal ¶
func (*Product) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.