db

Documentation

Index

• type File
  • func NewFileDB(storagePath string, key []byte) *File
  • func (db *File) Append(req *loggerv1alpha1.WriteRequest) (n int, err error)
  • func (db *File) ListAndWatch(ctx context.Context, address string, out chan<- []string) error
  • func (db *File) ReadAndWatch(ctx context.Context, address string, logName string, ...) error

Types

type File

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

func NewFileDB

func NewFileDB(storagePath string, key []byte) *File

func (*File) Append

func (db *File) Append(req *loggerv1alpha1.WriteRequest) (n int, err error)

func (*File) ListAndWatch

func (db *File) ListAndWatch(
	ctx context.Context,
	address string,
	out chan<- []string,
) error

func (*File) ReadAndWatch

func (db *File) ReadAndWatch(
	ctx context.Context,
	address string,
	logName string,
	out chan<- *loggerv1alpha1.ReadResponse,
) error