dao

Documentation

Index

• Constants
• Variables
• type CassandraRepository
  • func (r *CassandraRepository) ChangeLog(start, end time.Time, count int, lastId string) ([]*domain.ChangeSet, string, error)
  • func (r CassandraRepository) ReadConfig(ids []string) ([]*domain.ChangeSet, error)
  • func (r *CassandraRepository) ServiceChangeLog(id string, start, end time.Time, count int, lastId string) ([]*domain.ChangeSet, string, error)
  • func (r *CassandraRepository) UpdateConfig(cs *domain.ChangeSet) error

Constants

const (
	// Keyspace for C* storage
	Keyspace = "configservice"
	// CfConfig is CF where we store all config
	CfConfig = "configservice"
	// CfAudit is CF where we store a timeseries of all changes
	CfAudit = "audit"
	// CfAuditIndex is where we keep an index of which rows exist in our time series
	CfAuditIndex = "auditIndex"
	// CfAuditService is CF where we store a timeseries of all changes for a service
	CfAuditService = "auditService"
	// CfAuditServiceIndex is where we keep an index of which rows exist in our time series
	CfAuditServiceIndex = "auditServiceIndex"
)

Variables

var (
	// Cfs is a list of all active CFs, which we should monitor
	Cfs = []string{CfConfig, CfAudit, CfAuditIndex, CfAuditService, CfAuditServiceIndex}
)

Types

type CassandraRepository

type CassandraRepository struct{}

func (*CassandraRepository) ChangeLog

func (r *CassandraRepository) ChangeLog(start, end time.Time, count int, lastId string) ([]*domain.ChangeSet, string, error)

ChangeLog returns a list of changesets within a certain time range

func (CassandraRepository) ReadConfig

func (r CassandraRepository) ReadConfig(ids []string) ([]*domain.ChangeSet, error)

ReadConfig fetches N config definitions

func (*CassandraRepository) ServiceChangeLog

func (r *CassandraRepository) ServiceChangeLog(id string, start, end time.Time, count int, lastId string) ([]*domain.ChangeSet, string, error)

ServiceChangeLog returns a list of changesets within a certain time range for the given ID

func (*CassandraRepository) UpdateConfig

func (r *CassandraRepository) UpdateConfig(cs *domain.ChangeSet) error

UpdateConfig writes out a changeset