stores

Documentation

Index

• Variables
• type Activity
• type DirectlyFollowsRelation
• type EventStore
  • func NewEventStore(storage storage.Storage) *EventStore
  • func (es *EventStore) Append(event *events.Event) error
  • func (es *EventStore) Close()
  • func (es *EventStore) GetBinCount() (map[string]uint64, error)
  • func (es *EventStore) GetCount() uint64
  • func (es *EventStore) GetLast(count int) ([]events.Event, error)
• type KvStore
  • func NewKvStore(storage storage.Storage) *KvStore
  • func (kv *KvStore) Close()
  • func (kv *KvStore) Get(key []byte) ([]byte, error)
  • func (kv *KvStore) Increment(key []byte) (uint64, error)
  • func (kv *KvStore) Set(key []byte, value []byte) error
• type SbarStore
  • func NewSbarStore(store storage.Storage) (*SbarStore, error)
  • func (kv *SbarStore) Close()
  • func (kv *SbarStore) CountActivities() int
  • func (kv *SbarStore) CountDfRelations() int
  • func (kv *SbarStore) CountStartActivities() int
  • func (kv *SbarStore) DailyCountOfActivities(activities []string) (map[string]map[string]uint64, error)
  • func (kv *SbarStore) GetActivities() []Activity
  • func (kv *SbarStore) GetDfRelations() []DirectlyFollowsRelation
  • func (kv *SbarStore) GetDfRelationsWithinTimewindow(dfRelations [][]string, start time.Time, end time.Time) ([]DirectlyFollowsRelation, error)
  • func (kv *SbarStore) GetLastActivityForCase(caseId string) (string, error)
  • func (kv *SbarStore) RecordActivity(activity string, timestamp time.Time) error
  • func (kv *SbarStore) RecordActivityForCase(activity string, caseId string, timestamp time.Time) error
  • func (kv *SbarStore) RecordDirectlyFollowsRelation(from string, to string, timestamp time.Time) error
  • func (kv *SbarStore) RecordStartActivity(key string)

Variables

var (
	EventFlushCount = 100000 // decreasing this reduces memory utilization, but also performance
)

Types

type Activity

type Activity struct {
	Name   string `json:"name,omitempty"`
	Weight uint64 `json:"weight,omitempty"`
}

type DirectlyFollowsRelation

type DirectlyFollowsRelation struct {
	From   string `json:"from,omitempty"`
	To     string `json:"to,omitempty"`
	Weight uint64 `json:"weight,omitempty"`
}

type EventStore

type EventStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEventStore

func NewEventStore(storage storage.Storage) *EventStore

func (*EventStore) Append

func (es *EventStore) Append(event *events.Event) error

func (*EventStore) Close

func (es *EventStore) Close()

func (*EventStore) GetBinCount

func (es *EventStore) GetBinCount() (map[string]uint64, error)

func (*EventStore) GetCount

func (es *EventStore) GetCount() uint64

func (*EventStore) GetLast

func (es *EventStore) GetLast(count int) ([]events.Event, error)

type KvStore

type KvStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewKvStore

func NewKvStore(storage storage.Storage) *KvStore

func (*KvStore) Close

func (kv *KvStore) Close()

func (*KvStore) Get

func (kv *KvStore) Get(key []byte) ([]byte, error)

func (*KvStore) Increment

func (kv *KvStore) Increment(key []byte) (uint64, error)

func (*KvStore) Set

func (kv *KvStore) Set(key []byte, value []byte) error

type SbarStore

type SbarStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSbarStore

func NewSbarStore(store storage.Storage) (*SbarStore, error)

func (*SbarStore) Close

func (kv *SbarStore) Close()

func (*SbarStore) CountActivities

func (kv *SbarStore) CountActivities() int

func (*SbarStore) CountDfRelations

func (kv *SbarStore) CountDfRelations() int

func (*SbarStore) CountStartActivities

func (kv *SbarStore) CountStartActivities() int

func (*SbarStore) DailyCountOfActivities

func (kv *SbarStore) DailyCountOfActivities(activities []string) (map[string]map[string]uint64, error)

func (*SbarStore) GetActivities

func (kv *SbarStore) GetActivities() []Activity

func (*SbarStore) GetDfRelations

func (kv *SbarStore) GetDfRelations() []DirectlyFollowsRelation

func (*SbarStore) GetDfRelationsWithinTimewindow

func (kv *SbarStore) GetDfRelationsWithinTimewindow(dfRelations [][]string, start time.Time, end time.Time) ([]DirectlyFollowsRelation, error)

func (*SbarStore) GetLastActivityForCase

func (kv *SbarStore) GetLastActivityForCase(caseId string) (string, error)

func (*SbarStore) RecordActivity

func (kv *SbarStore) RecordActivity(activity string, timestamp time.Time) error

func (*SbarStore) RecordActivityForCase

func (kv *SbarStore) RecordActivityForCase(activity string, caseId string, timestamp time.Time) error

func (*SbarStore) RecordDirectlyFollowsRelation

func (kv *SbarStore) RecordDirectlyFollowsRelation(from string, to string, timestamp time.Time) error

func (*SbarStore) RecordStartActivity

func (kv *SbarStore) RecordStartActivity(key string)