service

Documentation

Index

• type Bulk
  • func (b *Bulk) Generate(section dao.Section, chanNumber int) map[int]dao.Section
  • func (b *Bulk) Init(conn configs.Content, d dao.Dao, es pkg.ES) error
  • func (b *Bulk) Run(channelData map[int]dao.Section, indexname string) error

Types

type Bulk

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

func (*Bulk) Generate

func (b *Bulk) Generate(section dao.Section, chanNumber int) map[int]dao.Section

func (*Bulk) Init

func (b *Bulk) Init(conn configs.Content, d dao.Dao, es pkg.ES) error

func (*Bulk) Run

func (b *Bulk) Run(channelData map[int]dao.Section, indexname string) error