Documentation
¶
Index ¶
- type Cursor
- type DBTX
- type InsertWhisperParams
- type IsRelayedParams
- type MarkRelayedParams
- type Queries
- func (q *Queries) DeleteAllRelayed(ctx context.Context) error
- func (q *Queries) DeleteAllWhispers(ctx context.Context) error
- func (q *Queries) GetCursor(ctx context.Context, agentID string) (string, error)
- func (q *Queries) InsertWhisper(ctx context.Context, arg InsertWhisperParams) error
- func (q *Queries) IsRelayed(ctx context.Context, arg IsRelayedParams) (int64, error)
- func (q *Queries) MarkRelayed(ctx context.Context, arg MarkRelayedParams) error
- func (q *Queries) PruneCursors(ctx context.Context, updatedAt string) (sql.Result, error)
- func (q *Queries) PruneRelayed(ctx context.Context, relayedAt string) (sql.Result, error)
- func (q *Queries) PruneWhispers(ctx context.Context, createdAt string) (sql.Result, error)
- func (q *Queries) RemoveCursor(ctx context.Context, agentID string) error
- func (q *Queries) UpsertCursor(ctx context.Context, arg UpsertCursorParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RelayedMurmur
- type UpsertCursorParams
- type Whisper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InsertWhisperParams ¶
type InsertWhisperParams struct {
ID string `json:"id"`
Scope string `json:"scope"`
Type string `json:"type"`
Source string `json:"source"`
Topic string `json:"topic"`
Content string `json:"content"`
Importance string `json:"importance"`
CreatedAt string `json:"created_at"`
AgentID sql.NullString `json:"agent_id"`
PrincipalID sql.NullString `json:"principal_id"`
PrincipalType sql.NullString `json:"principal_type"`
TeamID sql.NullString `json:"team_id"`
Metadata sql.NullString `json:"metadata"`
}
type IsRelayedParams ¶
type MarkRelayedParams ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) InsertWhisper ¶
func (q *Queries) InsertWhisper(ctx context.Context, arg InsertWhisperParams) error
func (*Queries) MarkRelayed ¶
func (q *Queries) MarkRelayed(ctx context.Context, arg MarkRelayedParams) error
func (*Queries) PruneCursors ¶
func (*Queries) PruneRelayed ¶
func (*Queries) PruneWhispers ¶
func (*Queries) RemoveCursor ¶
func (*Queries) UpsertCursor ¶
func (q *Queries) UpsertCursor(ctx context.Context, arg UpsertCursorParams) error
type RelayedMurmur ¶
type UpsertCursorParams ¶
type Whisper ¶
type Whisper struct {
ID string `json:"id"`
Scope string `json:"scope"`
Type string `json:"type"`
Source string `json:"source"`
Topic string `json:"topic"`
Content string `json:"content"`
Importance string `json:"importance"`
CreatedAt string `json:"created_at"`
AgentID sql.NullString `json:"agent_id"`
PrincipalID sql.NullString `json:"principal_id"`
PrincipalType sql.NullString `json:"principal_type"`
TeamID sql.NullString `json:"team_id"`
Metadata sql.NullString `json:"metadata"`
}
Click to show internal directories.
Click to hide internal directories.