proposal

Documentation

Index

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

Types

type ClickhouseAdapter

type ClickhouseAdapter struct {
}

func (ClickhouseAdapter) GetCategoryID

func (c ClickhouseAdapter) GetCategoryID(pl Payload) uint32

func (ClickhouseAdapter) GetInsertQuery

func (c ClickhouseAdapter) GetInsertQuery() string

func (ClickhouseAdapter) Values

func (c ClickhouseAdapter) Values(pl Payload) []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

type Payload

type Payload struct {
	Action   string
	Proposal *core.ProposalPayload
}