database

package

v0.0.0-...-5a2a765 Latest Latest Go to latest Published: Mar 28, 2020 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ContextKey string

type Database interface {
	Save(*Message) error
	Read(*Message) error
}

type Message struct {
	UUID      string
	Keyspace  string
	Key       string
	Name      string
	Operation string
	Value     int64
}

Message struct for doing an operation.

type MessageFn func(*Message) bool

type Stream interface {
	Save(*Message) error
	Read(context.Context, MessageFn) error
	StartWork(Database)
	StopWork()
}