program

Documentation

Index

• Constants
• type Program
  • func New(cfg *config.Config) (*Program, error)
  • func (p *Program) GetLastEventIds(key string) ([]byte, bool)
  • func (p *Program) GetLastEventIdsToJsonBytes() ([]byte, error)
  • func (p *Program) Run()
  • func (p *Program) SetLastEventIds(key string, val []byte)
  • func (p *Program) Stop()

Constants

const (
	LastEventIdsFileName = "last_event_ids.json"
)

Types

type Program

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

Program 程序实体

func New

func New(cfg *config.Config) (*Program, error)

New 创建程序实例

func (*Program) GetLastEventIds

func (p *Program) GetLastEventIds(key string) ([]byte, bool)

GetLastEventIds 读取上次结束位置lastEventId

func (*Program) GetLastEventIdsToJsonBytes

func (p *Program) GetLastEventIdsToJsonBytes() ([]byte, error)

GetLastEventIdsToJsonBytes 获取json字符

func (*Program) Run

func (p *Program) Run()

Run 启动程序

func (*Program) SetLastEventIds

func (p *Program) SetLastEventIds(key string, val []byte)

SetLastEventIds 设置最后监听事件id

func (*Program) Stop

func (p *Program) Stop()

Stop 程序结束要做的事