fsq

package

v0.7.3 Latest Latest Go to latest Published: Dec 27, 2025 License: MIT Imports: 7 Imported by: 0

Details

Rendered for

View Source

const (
	BoxNew = "new"
	BoxCur = "cur"
)

This section is empty.

func AgentAcksReceived(root, agent string) string

func AgentAcksSent(root, agent string) string

func AgentBase(root, agent string) string

func AgentInboxCur(root, agent string) string

func AgentInboxNew(root, agent string) string

func AgentInboxTmp(root, agent string) string

func AgentOutboxSent(root, agent string) string

func DeliverToInbox(root, agent, filename string, data []byte) (string, error)

DeliverToInbox writes a message using Maildir semantics (tmp -> new). It returns the final path in inbox/new.

func DeliverToInboxes(root string, recipients []string, filename string, data []byte) (map[string]string, error)

DeliverToInboxes writes a message to multiple inboxes. On failure, it attempts to roll back any prior deliveries.

func EnsureAgentDirs(root, agent string) error

func EnsureRootDirs(root string) error

func FindMessage(root, agent, filename string) (string, string, error)

func FindTmpFilesOlderThan(root string, cutoff time.Time) ([]string, error)

func ListAgents(root string) ([]string, error)

func MoveNewToCur(root, agent, filename string) error

func SyncDir(dir string) error

SyncDir fsyncs a directory to ensure directory entries are durable.

func WriteFileAtomic(dir, filename string, data []byte, perm os.FileMode) (string, error)

WriteFileAtomic writes data to a temporary file in dir and renames it into place.

This section is empty.