clickhouse

Documentation

Index

• Variables
• type Service
  • func (s *Service) Insert(message *common.FlowMessage)
  • func (s *Service) Name() string
  • func (s *Service) Ping() error
  • func (s *Service) RegisterModel(rule string, model *common.Model)
  • func (s *Service) Start(ctx context.Context) error
  • func (s *Service) Stop() error
  • func (s *Service) Worker(ctx context.Context)
• type Settings

Variables

var Module = module.Module{
	{Constructor: newSettings},
	{Constructor: newService},
}

Module application

Types

type Service

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

func (*Service) Insert

func (s *Service) Insert(message *common.FlowMessage)

func (*Service) Name

func (s *Service) Name() string

func (*Service) Ping

func (s *Service) Ping() error

func (*Service) RegisterModel

func (s *Service) RegisterModel(rule string, model *common.Model)

func (*Service) Start

func (s *Service) Start(ctx context.Context) error

func (*Service) Stop

func (s *Service) Stop() error

func (*Service) Worker

func (s *Service) Worker(ctx context.Context)

type Settings

type Settings struct {
	Address      string
	Username     string
	Password     string
	Database     string
	FlowTable    string
	Debug        bool
	BatchSize    int
	BatchTimeout time.Duration

	ReadTimeout  int
	WriteTimeout int
}