ack

package

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

Details

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

Repository

github.com/avivsinai/agent-message-queue

Links

Open Source Insights

Documentation ¶

Overview ¶

Package ack provides acknowledgment tracking for messages. Acks are stored as JSON files in the sender's received/ and receiver's sent/ directories for coordination and audit.

Index ¶

type Ack
- func New(msgID, thread, from, to string, received time.Time) Ack
- func Read(path string) (Ack, error)
- func (a Ack) Marshal() ([]byte, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Ack ¶

type Ack struct {
	Schema   int    `json:"schema"`
	MsgID    string `json:"msg_id"`
	Thread   string `json:"thread"`
	From     string `json:"from"`
	To       string `json:"to"`
	Received string `json:"received"`
}

Ack records that a message was received and acknowledged.

func New ¶

func New(msgID, thread, from, to string, received time.Time) Ack

func Read ¶ added in v0.4.0

func Read(path string) (Ack, error)

func (Ack) Marshal ¶

func (a Ack) Marshal() ([]byte, error)

Source Files ¶

View all Source files

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