Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Ring ¶ added in v1.5.2
type Ring struct {
// contains filtered or unexported fields
}
func (*Ring) ForceBatchOrShard ¶ added in v1.5.2
func (ring *Ring) ForceBatchOrShard(_ interface{})
func (*Ring) MakeRoom ¶ added in v1.5.2
func (ring *Ring) MakeRoom(newMsg *model.InputMessage)
func (*Ring) PutMsgNolock ¶ added in v1.5.2
func (ring *Ring) PutMsgNolock(msg *model.InputMessage)
assumes ring.mux is locked, and msg.Offset is in range [ring.ringGroundOff, ring.ringGroundOff+ring.ringCap)
type Service ¶
TaskService holds the configuration for each task
func NewTaskService ¶
func NewTaskService(cfg *config.Config, taskCfg *config.TaskConfig) (service *Service)
NewTaskService creates an instance of new tasks with kafka, clickhouse and paser instances
type Sharder ¶ added in v1.5.2
type Sharder struct {
// contains filtered or unexported fields
}
func NewSharder ¶ added in v1.5.2
func (*Sharder) ForceFlush ¶ added in v1.5.2
func (sh *Sharder) ForceFlush(arg interface{})
type ShardingPolicy ¶ added in v1.5.2
type ShardingPolicy struct {
// contains filtered or unexported fields
}
func NewShardingPolicy ¶ added in v1.5.2
func NewShardingPolicy(shardingKey, shardingPolicy string, dims []string, ckNum int) (policy *ShardingPolicy, err error)
Click to show internal directories.
Click to hide internal directories.