riakdaoimpl

package

v0.0.0-...-977a47e Latest Latest Go to latest Published: Mar 14, 2016 License: GPL-3.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/PeerioTechnologies/chronicler

Documentation ¶

Index ¶

Variables
func InitIndexBucket(cluster *riak.Cluster, bucket string)
func StartCluster(addresses []string, minConnections uint16, maxConnections uint16, ...) (*riak.Cluster, error)
type LogIndexRiakDAO
- func NewLogIndexRiakDAO(cluster *riak.Cluster, indexBucket string) *LogIndexRiakDAO
type LogRecordRiakDao
- func NewLogRecordRiakDao(cluster *riak.Cluster, logBucket string) *LogRecordRiakDao
type TimelineConfilctResolver
- func (cr *TimelineConfilctResolver) Resolve(objs []*riak.Object) []*riak.Object
type TimelineRiakDaoImpl
- func NewTimelineRiakDaoImpl(cluster *riak.Cluster, indexBucket string, logBucket string, daysToKeep int) *TimelineRiakDaoImpl

Constants ¶

This section is empty.

Variables ¶

View Source

var EnableDebugLogging = false

If true, debug messages will be written to the log

View Source

var TestCluster *riak.Cluster

Functions ¶

func InitIndexBucket ¶

func InitIndexBucket(cluster *riak.Cluster, bucket string)

func StartCluster ¶

func StartCluster(addresses []string, minConnections uint16, maxConnections uint16, logIndexBucket string, enableDebug bool) (*riak.Cluster, error)

Types ¶

type LogIndexRiakDAO ¶

type LogIndexRiakDAO struct {
	Cluster     *riak.Cluster
	Resolver    *TimelineConfilctResolver
	IndexBucket string
}

func NewLogIndexRiakDAO ¶

func NewLogIndexRiakDAO(cluster *riak.Cluster, indexBucket string) *LogIndexRiakDAO

func (*LogIndexRiakDAO) AppendToLogIndex ¶

func (dao *LogIndexRiakDAO) AppendToLogIndex(userId string, entry ent.IndexEntry) error

func (*LogIndexRiakDAO) GetLogIndex ¶

func (dao *LogIndexRiakDAO) GetLogIndex(userId string) (ent.TimelineIndex, error)

func (*LogIndexRiakDAO) Ping ¶

func (dao *LogIndexRiakDAO) Ping() (bool, error)

type LogRecordRiakDao ¶

type LogRecordRiakDao struct {
	Cluster   *riak.Cluster
	LogBucket string
}

func NewLogRecordRiakDao ¶

func NewLogRecordRiakDao(cluster *riak.Cluster, logBucket string) *LogRecordRiakDao

func (*LogRecordRiakDao) DeleteLogRecord ¶

func (dao *LogRecordRiakDao) DeleteLogRecord(logId string) error

func (*LogRecordRiakDao) GetLogRecord ¶

func (dao *LogRecordRiakDao) GetLogRecord(logId string) (string, error)

func (*LogRecordRiakDao) Ping ¶

func (dao *LogRecordRiakDao) Ping() (bool, error)

func (*LogRecordRiakDao) SaveLogRecord ¶

func (dao *LogRecordRiakDao) SaveLogRecord(logId string, logRecord string) error

type TimelineConfilctResolver ¶

type TimelineConfilctResolver struct {
}

func (*TimelineConfilctResolver) Resolve ¶

func (cr *TimelineConfilctResolver) Resolve(objs []*riak.Object) []*riak.Object

type TimelineRiakDaoImpl ¶

type TimelineRiakDaoImpl struct {
	Cluster      *riak.Cluster
	IndexDao     *LogIndexRiakDAO
	LogRecordDao *LogRecordRiakDao
	SnowFlake    *gosnow.SnowFlake
	DaysToKeep   int
}

Implements TimelineDAO

func NewTimelineRiakDaoImpl ¶

func NewTimelineRiakDaoImpl(cluster *riak.Cluster, indexBucket string, logBucket string, daysToKeep int) *TimelineRiakDaoImpl

func (*TimelineRiakDaoImpl) GetTimeline ¶

func (dao *TimelineRiakDaoImpl) GetTimeline(id string) (ent.TimelineIndex, error)

func (*TimelineRiakDaoImpl) ReportState ¶

func (dao *TimelineRiakDaoImpl) ReportState() (stateCode, stateDescription string)

func (*TimelineRiakDaoImpl) SaveLog ¶

func (dao *TimelineRiakDaoImpl) SaveLog(userId string, level string, typeStr string, msg string) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL