at

package

v0.0.1 Latest Latest Go to latest Published: Feb 19, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(service string) *Client

func (c *Client) GetIdentity(ctx context.Context, raw string) (*identity.Identity, error)

func (c *Client) GetRecord(ctx context.Context, collection, repo, rkey string) (*RecordWithIdentity, error)

func (c *Client) GetRepo(ctx context.Context, repo string) (*RepoWithIdentity, error)

func (c *Client) ListRecords(ctx context.Context, collection, repo string) (*RecordsWithIdentity, error)

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

func NewJetstreamClient() *JetStreamClient

func (c *JetStreamClient) Err() <-chan error

func (c *JetStreamClient) Out() <-chan *models.Event

func (c *JetStreamClient) Start(ctx context.Context, cxs, dids []string, cursor *int64)

type Record struct {
	Uri   string
	Cid   string
	Value *json.RawMessage
}

func NewRecordFromGet(r *agnostic.RepoGetRecord_Output) *Record

func NewRecordFromList(r *agnostic.RepoListRecords_Record) *Record

func (r *Record) Collection() string

type RecordWithIdentity struct {
	Identity *identity.Identity
	Record   *Record
}

type RecordsWithIdentity struct {
	Identity *identity.Identity
	Records  []*Record
}

func (r *RecordsWithIdentity) Collection() string

type RepoWithIdentity struct {
	Identity *identity.Identity
	Repo     *comatproto.RepoDescribeRepo_Output
}