service

Documentation

Index

• type REST
  • func NewREST(s Storage, address string, timeout time.Duration) *REST
  • func (r REST) Start(context.Context) error
  • func (r REST) Stop() error
• type Storage

Types

type REST

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

func NewREST

func NewREST(s Storage, address string, timeout time.Duration) *REST

func (REST) Start

func (r REST) Start(context.Context) error

func (REST) Stop

func (r REST) Stop() error

type Storage

type Storage interface {
	Start(context.Context) error
	Stop() error

	WriteOne(b bucket.Bucket, e log.Entry) (map[string]any, error)
	WriteBatch(b bucket.Bucket, e []log.Entry) (map[string]any, error)

	All(b bucket.Bucket) ([]log.Entry, error)
	Last(b bucket.Bucket, n uint64) ([]log.Entry, error)
	Count(b bucket.Bucket) (uint64, error)
}