postgresql

Documentation

Index

• type DuplicationError
  • func NewDuplicationError(msg string) *DuplicationError
  • func (de *DuplicationError) Duplication()
  • func (de *DuplicationError) Error() string
• type Store
  • func NewStore(connStr string, wt time.Duration, rt time.Duration) (*Store, error)
  • func (s *Store) AlterKeysTable() error
  • func (s *Store) CreateEventsTable() error
  • func (s *Store) CreateKey(rk *key.RequestKey) (*key.ResponseKey, error)
  • func (s *Store) CreateKeysTable() error
  • func (s *Store) CreateProviderSetting(setting *provider.Setting) (*provider.Setting, error)
  • func (s *Store) CreateProviderSettingsTable() error
  • func (s *Store) DeleteKey(id string) error
  • func (s *Store) DropEventsTable() error
  • func (s *Store) DropKeysTable() error
  • func (s *Store) DropProviderSettingsTable() error
  • func (s *Store) GetAllKeys() ([]*key.ResponseKey, error)
  • func (s *Store) GetAllProviderSettings() ([]*provider.Setting, error)
  • func (s *Store) GetEventDataPoints(start, end, increment int64, tags, keyIds []string) ([]*event.DataPoint, error)
  • func (s *Store) GetKey(keyId string) (*key.ResponseKey, error)
  • func (s *Store) GetKeysByTag(tag string) ([]*key.ResponseKey, error)
  • func (s *Store) GetLatencyPercentiles(start, end int64, tags, keyIds []string) ([]float64, error)
  • func (s *Store) GetProviderSetting(id string) (*provider.Setting, error)
  • func (s *Store) GetUpdatedKeys(interval time.Duration) ([]*key.ResponseKey, error)
  • func (s *Store) GetUpdatedProviderSettings(interval time.Duration) ([]*provider.Setting, error)
  • func (s *Store) InsertEvent(e *event.Event) error
  • func (s *Store) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, error)
  • func (s *Store) UpdateProviderSetting(id string, setting *provider.Setting) (*provider.Setting, error)

Types

type DuplicationError

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

func NewDuplicationError

func NewDuplicationError(msg string) *DuplicationError

func (*DuplicationError) Duplication

func (de *DuplicationError) Duplication()

func (*DuplicationError) Error

func (de *DuplicationError) Error() string

type Store

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

func NewStore

func NewStore(connStr string, wt time.Duration, rt time.Duration) (*Store, error)

func (*Store) AlterKeysTable

func (s *Store) AlterKeysTable() error

func (*Store) CreateEventsTable

func (s *Store) CreateEventsTable() error

func (*Store) CreateKey

func (s *Store) CreateKey(rk *key.RequestKey) (*key.ResponseKey, error)

func (*Store) CreateKeysTable

func (s *Store) CreateKeysTable() error

func (*Store) CreateProviderSetting

func (s *Store) CreateProviderSetting(setting *provider.Setting) (*provider.Setting, error)

func (*Store) CreateProviderSettingsTable

func (s *Store) CreateProviderSettingsTable() error

func (*Store) DeleteKey

func (s *Store) DeleteKey(id string) error

func (*Store) DropEventsTable

func (s *Store) DropEventsTable() error

func (*Store) DropKeysTable

func (s *Store) DropKeysTable() error

func (*Store) DropProviderSettingsTable

func (s *Store) DropProviderSettingsTable() error

func (*Store) GetAllKeys

func (s *Store) GetAllKeys() ([]*key.ResponseKey, error)

func (*Store) GetAllProviderSettings

func (s *Store) GetAllProviderSettings() ([]*provider.Setting, error)

func (*Store) GetEventDataPoints

func (s *Store) GetEventDataPoints(start, end, increment int64, tags, keyIds []string) ([]*event.DataPoint, error)

func (*Store) GetKey

func (s *Store) GetKey(keyId string) (*key.ResponseKey, error)

func (*Store) GetKeysByTag

func (s *Store) GetKeysByTag(tag string) ([]*key.ResponseKey, error)

func (*Store) GetLatencyPercentiles

func (s *Store) GetLatencyPercentiles(start, end int64, tags, keyIds []string) ([]float64, error)

func (*Store) GetProviderSetting

func (s *Store) GetProviderSetting(id string) (*provider.Setting, error)

func (*Store) GetUpdatedKeys

func (s *Store) GetUpdatedKeys(interval time.Duration) ([]*key.ResponseKey, error)

func (*Store) GetUpdatedProviderSettings

func (s *Store) GetUpdatedProviderSettings(interval time.Duration) ([]*provider.Setting, error)

func (*Store) InsertEvent

func (s *Store) InsertEvent(e *event.Event) error

func (*Store) UpdateKey

func (s *Store) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, error)

func (*Store) UpdateProviderSetting

func (s *Store) UpdateProviderSetting(id string, setting *provider.Setting) (*provider.Setting, error)