msg_storer

README

storer

test

DEBUG_LEVEL=error TEST_MODE=true go test -race -v . -bench=.

Documentation

Index

• Constants
• Variables
• func Module(scope string) fx.Option
• type Params
• type Storer
  • func (sr *Storer) GetArchivedFileBySeq(dstPath string, seq uint64) (string, error)
  • func (sr *Storer) MsgStore(dstPath string, seq uint64, rawData []byte) (string, error)

Constants

const (
	DefaultCurrentDB    = "current.db"
	DefaultArchiveIndex = "archive.index"
	DefaultDatastore    = "./datastore"

	DefaultDomain  = "onglai-msg"
	DefaultSubject = "%s.archive.bucket.job.%s"
)

Variables

var (
	ErrSeqNotFound = errors.New("Sequence not fount in the index.")
)

Functions

func Module

func Module(scope string) fx.Option

Types

type Params

type Params struct {
	fx.In
	NATSConnector *nats_connector.NATSConnector
	Lifecycle     fx.Lifecycle
	Logger        *zap.Logger
}

type Storer

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

func (*Storer) GetArchivedFileBySeq

func (sr *Storer) GetArchivedFileBySeq(dstPath string, seq uint64) (string, error)

func (*Storer) MsgStore

func (sr *Storer) MsgStore(dstPath string, seq uint64, rawData []byte) (string, error)