ganalytics

Documentation

Index

• type LastKeyEnd
• type Properties
  • func (p *Properties) ToJsonBytes() []byte
• type StateFile
  • func NewStateFile(config map[string]string) (*StateFile, error)
  • func (s *StateFile) GetKey(key string) (int, LastKeyEnd)
  • func (s *StateFile) GetLastCount() int
  • func (s *StateFile) GetLastEndTS() int
  • func (s *StateFile) GetLastKeyEndTS(key string) int
  • func (s *StateFile) GetLastRequestTS() int
  • func (s *StateFile) GetLastStartTS() int
  • func (s *StateFile) Save() error
  • func (s *StateFile) UpdateLastCount(count int)
  • func (s *StateFile) UpdateLastEndTS(ts int)
  • func (s *StateFile) UpdateLastKeyEndTS(key string, ts int)
  • func (s *StateFile) UpdateLastRequestTS(ts int)
  • func (s *StateFile) UpdateLastStartTS(ts int)

Types

type LastKeyEnd

type LastKeyEnd struct {
	Key  string `json:"key"`
	Time int    `json:"time"`
}

type Properties

type Properties struct {
	LastStartTS   int          `json:"last_start_ts"`
	LastEndTS     int          `json:"last_end_ts"`
	LastCount     int          `json:"last_count"`
	LastRequestTS int          `json:"last_request_ts"`
	LastUpdateTS  int          `json:"last_update_ts"`
	LastKeyEndTS  []LastKeyEnd `json:"last_keys_end_ts"`
}

func (*Properties) ToJsonBytes

func (p *Properties) ToJsonBytes() []byte

type StateFile

type StateFile struct {
	FileName    string
	FilePath    string
	StorageType string
	// contains filtered or unexported fields
}

func NewStateFile

func NewStateFile(config map[string]string) (*StateFile, error)

func (*StateFile) GetKey

func (s *StateFile) GetKey(key string) (int, LastKeyEnd)

func (*StateFile) GetLastCount

func (s *StateFile) GetLastCount() int

func (*StateFile) GetLastEndTS

func (s *StateFile) GetLastEndTS() int

func (*StateFile) GetLastKeyEndTS

func (s *StateFile) GetLastKeyEndTS(key string) int

func (*StateFile) GetLastRequestTS

func (s *StateFile) GetLastRequestTS() int

func (*StateFile) GetLastStartTS

func (s *StateFile) GetLastStartTS() int

func (*StateFile) Save

func (s *StateFile) Save() error

func (*StateFile) UpdateLastCount

func (s *StateFile) UpdateLastCount(count int)

func (*StateFile) UpdateLastEndTS

func (s *StateFile) UpdateLastEndTS(ts int)

func (*StateFile) UpdateLastKeyEndTS

func (s *StateFile) UpdateLastKeyEndTS(key string, ts int)

func (*StateFile) UpdateLastRequestTS

func (s *StateFile) UpdateLastRequestTS(ts int)

func (*StateFile) UpdateLastStartTS

func (s *StateFile) UpdateLastStartTS(ts int)