db

type DB interface {
	Close() error
	ReadStreamLogs(handle string) []*types.StreamLog
	ReadStreamMessages(handle string) []*types.StreamMessage
	InsertStreamLog(vLog *types.StreamLog)
	InsertStreamMessage(msg *types.StreamMessage)
}