msg_storer

package

v0.0.1 Latest Latest Go to latest Published: Dec 16, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/weedbox/whisper-modules

Links

Open Source Insights

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 ¶

View Source

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

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

Variables ¶

View Source

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)

Source Files ¶

View all Source files

msg_store.go

Directories ¶

Path	Synopsis
gcs_uploader
local_uploader

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL