commitlog

package

v0.0.0-...-31bb6df Latest Latest Go to latest Published: Jan 28, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CommitListener func(bool)

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

func NewCommitLog(ds datastore.Datastore) (*CommitLog, error)

func (cl *CommitLog) GetOrNewTopic(topicName string) (*Topic, error)

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

func NewEntry(message *api.Message, listener CommitListener) *Entry

type StreamFn = func(message *api.Message) error

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

func (s *Subscriber) Close()

func (s *Subscriber) Commit(offset int64)

func (s *Subscriber) Stream(callback StreamFn) error

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

func (topic *Topic) AddEntry(entry *Entry)

func (topic *Topic) NewSubscriber(id string, offset int64, since int64) *Subscriber