asyncwrite

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Enqueued    = "goncho_async_enqueued"
	Flushed     = "goncho_async_flushed"
	Retry       = "goncho_async_retry"
	FlushFailed = "goncho_async_flush_failed"
	Shutdown    = "goncho_async_shutdown"
	Closed      = "goncho_async_closed"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Result 

type Result struct {
	Code     string
	Flushed  int
	Pending  int
	Evidence []string
}

func (Result) HasEvidence 

func (r Result) HasEvidence(code string) bool

type Writer 

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

func NewWriter 

func NewWriter(flusher session.Flusher) *Writer

func (*Writer) Cache 

func (w *Writer) Cache(item session.MemorySession)

func (*Writer) Enqueue 

func (w *Writer) Enqueue(session session.MemorySession) Result

func (*Writer) FlushAll 

func (w *Writer) FlushAll() Result

func (*Writer) Shutdown 

func (w *Writer) Shutdown() Result

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.