eventstore

package module
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 15, 2020 License: MIT Imports: 12 Imported by: 1

README

EventStore

GoDoc

High performance event store which is used by Brobridge Gravity.

License

Licensed under the MIT License

Authors

Copyright(c) 2020 Fred Chien fred@brobridge.com

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BytesToUint64 

func BytesToUint64(data []byte) uint64

func GetFixedSizeBytes 

func GetFixedSizeBytes(size int, str string) []byte

func StrToBytes 

func StrToBytes(s string) []byte

func Uint64ToBytes 

func Uint64ToBytes(n uint64) []byte

Types

type Counter 

type Counter uint64

func (*Counter) Count 

func (counter *Counter) Count() uint64

func (*Counter) Increase 

func (counter *Counter) Increase(delta uint64) uint64

func (*Counter) SetCount 

func (counter *Counter) SetCount(val uint64)

func (*Counter) String 

func (counter *Counter) String() string

type Event 

type Event struct {
	Sequence uint64
	Data     []byte
	// contains filtered or unexported fields
}

func NewEvent 

func NewEvent() *Event

func (*Event) Ack 

func (event *Event) Ack()

type EventStore 

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

func CreateEventStore 

func CreateEventStore(options *Options) (*EventStore, error)

func (*EventStore) Close 

func (eventstore *EventStore) Close()

func (*EventStore) GetStore 

func (eventstore *EventStore) GetStore(storeName string) (*Store, error)

func (*EventStore) RecoverSnapshot added in v0.0.2 

func (eventstore *EventStore) RecoverSnapshot(store *Store) error

func (*EventStore) SetSnapshotHandler 

func (eventstore *EventStore) SetSnapshotHandler(fn func(*SnapshotRequest) error)

func (*EventStore) TakeSnapshot 

func (eventstore *EventStore) TakeSnapshot(store *Store, seq uint64, data []byte) error

func (*EventStore) UnregisterStore 

func (eventstore *EventStore) UnregisterStore(name string)

type Options 

type Options struct {
	DatabasePath    string
	EnabledSnapshot bool
	RocksdbOptions  *gorocksdb.Options
	SnapshotOptions *SnapshotOptions
}

func NewOptions 

func NewOptions() *Options

type SnapshotController 

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

func NewSnapshotController 

func NewSnapshotController(options *SnapshotOptions) *SnapshotController

func (*SnapshotController) RecoverSnapshot added in v0.0.2 

func (ss *SnapshotController) RecoverSnapshot(store *Store) error

func (*SnapshotController) Request 

func (ss *SnapshotController) Request(store *Store, seq uint64, data []byte) error

func (*SnapshotController) SetHandler 

func (ss *SnapshotController) SetHandler(fn func(*SnapshotRequest) error)

type SnapshotOptions 

type SnapshotOptions struct {
	WorkerCount int32
	BufferSize  int
}

func NewSnapshotOptions 

func NewSnapshotOptions() *SnapshotOptions

type SnapshotRequest 

type SnapshotRequest struct {
	Store    *Store
	Sequence uint64
	Data     []byte
}

func NewSnapshotRequest 

func NewSnapshotRequest() *SnapshotRequest

func (*SnapshotRequest) Delete 

func (request *SnapshotRequest) Delete(collection []byte, key []byte) error

func (*SnapshotRequest) Get 

func (request *SnapshotRequest) Get(collection []byte, key []byte) ([]byte, error)

func (*SnapshotRequest) UpdateDurableState added in v0.0.2 

func (request *SnapshotRequest) UpdateDurableState(collection []byte) error

func (*SnapshotRequest) Upsert 

func (request *SnapshotRequest) Upsert(collection []byte, key []byte, fn func(origin []byte) ([]byte, error)) error

type Store 

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

func NewStore 

func NewStore(eventstore *EventStore, storeName string) (*Store, error)

func (*Store) Close 

func (store *Store) Close()

func (*Store) DispatchEvent 

func (store *Store) DispatchEvent()

func (*Store) GetColumnFamailyHandle 

func (store *Store) GetColumnFamailyHandle(name string) (*gorocksdb.ColumnFamilyHandle, error)

func (*Store) GetDurableState 

func (store *Store) GetDurableState(durableName string) (uint64, error)

func (*Store) GetLastSequence 

func (store *Store) GetLastSequence() uint64

func (*Store) Subscribe 

func (store *Store) Subscribe(durableName string, startAt uint64, fn StoreHandler) (*Subscription, error)

func (*Store) UpdateDurableState 

func (store *Store) UpdateDurableState(durableName string, lastSeq uint64) error

func (*Store) Write 

func (store *Store) Write(data []byte) (uint64, error)

type StoreHandler 

type StoreHandler func(*Event)

type Subscription 

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

func NewSubscription 

func NewSubscription(store *Store, durableName string, startAt uint64, iterator *gorocksdb.Iterator, fn StoreHandler) *Subscription

func (*Subscription) Close 

func (sub *Subscription) Close()

func (*Subscription) Trigger 

func (sub *Subscription) Trigger() error

func (*Subscription) Watch 

func (sub *Subscription) Watch()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.