Versions in this module Expand all Collapse all v1 v1.0.1 Aug 29, 2026 v1.0.0 Aug 29, 2026 Changes in this version + const MethodGC + const MethodGet + const MethodList + const MethodObserve + const MethodObserveBatch + const MethodPing + const MethodSubscribe + const MethodSummary + const ProtocolVersion + const SocketPathEnv + var ErrProtocol = errors.New("aht broker protocol error") + var ErrUnavailable = errors.New("aht broker unavailable") + func IsUnavailable(err error) bool + func SocketPath(storePath string) string + type Client struct + func NewClient(storePath string) *Client + func (c *Client) GC(ctx context.Context, deleteAfter time.Duration) (registry.GCResult, error) + func (c *Client) Get(ctx context.Context, id string) (registry.Session, error) + func (c *Client) List(ctx context.Context, filter registry.Filter) ([]registry.Session, error) + func (c *Client) Observe(ctx context.Context, observation registry.Observation) (registry.Session, error) + func (c *Client) ObserveBatch(ctx context.Context, observations []registry.Observation) ([]registry.Session, error) + func (c *Client) Ping(ctx context.Context) error + func (c *Client) SocketPath() string + func (c *Client) Subscribe(ctx context.Context, filter registry.Filter) (*Subscription, error) + func (c *Client) Summary(ctx context.Context, filter registry.Filter) ([]registry.Summary, error) + type Error struct + Code string + Message string + type RemoteError struct + Code string + Message string + func (e *RemoteError) Error() string + type Request struct + DeleteAfter time.Duration + Filter registry.Filter + ID string + Method string + Observation *registry.Observation + Observations []registry.Observation + SessionID string + Version int + type Response struct + Error *Error + GC *registry.GCResult + ID string + Now time.Time + Session *registry.Session + Sessions []registry.Session + Snapshot *registry.StateSnapshot + Summaries []registry.Summary + Type string + Version int + type Store struct + func NewStore(storePath string) *Store + func (s *Store) Client() *Client + func (s *Store) GC(ctx context.Context, deleteAfter time.Duration) (registry.GCResult, error) + func (s *Store) Get(ctx context.Context, id string) (registry.Session, error) + func (s *Store) List(ctx context.Context, filter registry.Filter) ([]registry.Session, error) + func (s *Store) Observe(ctx context.Context, observation registry.Observation) (registry.Session, error) + func (s *Store) ObserveBatch(ctx context.Context, observations []registry.Observation) ([]registry.Session, error) + func (s *Store) SummaryByTmuxSession(ctx context.Context, filter registry.Filter) ([]registry.Summary, error) + func (s *Store) SummaryByTmuxSessionWithOptions(ctx context.Context, options registry.SummaryOptions) ([]registry.Summary, error) + type Subscription struct + Errors <-chan error + Snapshots <-chan registry.StateSnapshot + func (s *Subscription) Close()
Go to main page