amqpclickhouse

Jun 6, 2023

Changes in this version

type Metric

+ Expirable bool

Oct 25, 2022

Changes in this version

type Metric

+ DomainID uint64

Aug 2, 2022

Changes in this version

+ const DATE_LAYOUT

+ const DATE_TIME_LAYOUT

+ type Batch struct

+ LastSendAt time.Time

+ MaxSize int

+ func NewBatch() Batch

+ func (b *Batch) AddMetric(metric Metric)

+ func (b *Batch) MarshalJSON() ([]byte, error)

+ func (b *Batch) Reset()

+ func (b *Batch) Size() int

+ type ClickHouseService struct

+ BatchSize int

+ BatchTTL time.Duration

+ BridgeExchange string

+ DRY bool

+ Exchange string

+ Period time.Duration

+ Queue string

+ RoutingKey string

+ func NewClickHouseService(ctx context.Context, connection *rabbit.Connection) (*ClickHouseService, error)

+ func (chs *ClickHouseService) AddMetric(metric Metric) error

+ func (chs *ClickHouseService) Collect(ctx context.Context) error

+ func (chs *ClickHouseService) ForceAddMetric(metric Metric) error

+ func (chs *ClickHouseService) Init(ctx context.Context) error

+ func (chs *ClickHouseService) Shutdown() error

+ type Metric struct

+ CompanyID uint64

+ CreatedAt time.Time

+ Duration float64

+ Labels []string

+ ModelID uint64

+ ModelType string

+ Name string

+ UserID uint64

+ Value uint64

+ ValueDateTime time.Time

+ ValueFloat float64

+ ValueString string

+ func NewMetric(name string, createdAt *time.Time, value uint64, valueFloat float64, ...) Metric

+ func (m *Metric) MarshalJSON() ([]byte, error)