vote

Documentation

Index

• type ClickhouseAdapter
  • func (c ClickhouseAdapter) GetCategoryID(v *core.VotePayload) uint32
  • func (c ClickhouseAdapter) GetInsertQuery() string
  • func (c ClickhouseAdapter) Values(v *core.VotePayload) []any
• type Consumer
  • func NewConsumer(nc *nats.Conn, st storage) *Consumer
  • func (c *Consumer) Start(ctx context.Context) error

Types

type ClickhouseAdapter

type ClickhouseAdapter struct {
}

func (ClickhouseAdapter) GetCategoryID

func (c ClickhouseAdapter) GetCategoryID(v *core.VotePayload) uint32

func (ClickhouseAdapter) GetInsertQuery

func (c ClickhouseAdapter) GetInsertQuery() string

func (ClickhouseAdapter) Values

func (c ClickhouseAdapter) Values(v *core.VotePayload) []any

type Consumer

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

func NewConsumer

func NewConsumer(nc *nats.Conn, st storage) *Consumer

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context) error