rsql

package module

Go to main page

Versions in this module

v1

v1.0.0

Sep 10, 2026

Changes in this version

type NamespaceAdmin

+ func (n NamespaceAdmin) ListAll(ctx context.Context) ([]NamespaceRecord, error)

type NamespaceConfig

+ Synchronous string

+ type NamespaceListOptions struct

+ Cursor string

+ Limit int

+ type NamespacePage struct

+ Data []NamespaceRecord

+ NextCursor string

v1.0.0-rc.1

Jul 27, 2026

v0

v0.4.0

Jul 26, 2026

Changes in this version

+ const PreferIgnoreDuplicates

+ const PreferMergeDuplicates

+ const PreferReturnRepresentation

+ type APIError struct

+ Code string

+ Header http.Header

+ Message string

+ Status int

+ func (e *APIError) Error() string

+ type AdminClient struct

+ Namespaces NamespaceAdmin

+ type ChangelogClient struct

+ func (c ChangelogClient) List(ctx context.Context, table string, limit int, offset int) ([]ChangelogEntry, error)

+ type ChangelogEntry struct

+ Action string

+ Detail json.RawMessage

+ ID int

+ Meta json.RawMessage

+ Table string

+ Timestamp string

+ type Client struct

+ func New(config Config) (*Client, error)

+ func (c *Client) Admin() AdminClient

+ func (c *Client) CloseIdleConnections()

+ func (c *Client) Database(namespace string) (*DatabaseClient, error)

+ type ColumnDefinition struct

+ Auto bool

+ Default any

+ Formula string

+ Index bool

+ Max *float64

+ MaxLength int

+ Metadata json.RawMessage

+ Min *float64

+ Name string

+ NotNull bool

+ Options []string

+ Pattern string

+ PrimaryKey bool

+ ReadOnly bool

+ Type string

+ Unique bool

+ type Config struct

+ BaseURL string

+ HTTPClient *http.Client

+ Token string

+ type DatabaseClient struct

+ Changelog ChangelogClient

+ Events EventsClient

+ Overview OverviewClient

+ Query QueryClient

+ Tables TablesClient

+ func (d *DatabaseClient) Forward(writer http.ResponseWriter, incoming *http.Request, route DatabaseRoute) error

+ func (d *DatabaseClient) Namespace() string

+ func (d *DatabaseClient) RoundTrip(ctx context.Context, incoming *http.Request, route DatabaseRoute) (*http.Response, error)

+ func (d *DatabaseClient) Table(name string) (*TableClient, error)

+ type DatabaseRoute struct

+ Path string

+ RawQuery string

+ type EventStream struct

+ func (s *EventStream) Close() error

+ func (s *EventStream) Err() error

+ func (s *EventStream) Event() SSEEvent

+ func (s *EventStream) Header() http.Header

+ func (s *EventStream) Next() bool

+ type EventsClient struct

+ func (e EventsClient) Subscribe(ctx context.Context, options SubscribeOptions) (*EventStream, error)

+ type ImportOptions struct

+ Body io.Reader

+ ContentType string

+ Filename string

+ type IndexCreateRequest struct

+ Columns []string

+ Meta json.RawMessage

+ Name string

+ Type string

+ type IndexesClient struct

+ func (i IndexesClient) Create(ctx context.Context, request IndexCreateRequest) error

+ func (i IndexesClient) Delete(ctx context.Context, name string, meta json.RawMessage) error

+ type ListMeta struct

+ FilterCount int

+ Limit int

+ Offset int

+ TotalCount int

+ type MutateOptions struct

+ Meta json.RawMessage

+ Prefer string

+ type MutationResult struct

+ Data []map[string]any

+ Deleted int

+ Inserted int

+ Updated int

+ type NamespaceAdmin struct

+ func (n NamespaceAdmin) Create(ctx context.Context, definition NamespaceDefinition) (NamespaceRecord, error)

+ func (n NamespaceAdmin) Delete(ctx context.Context, namespace string) error

+ func (n NamespaceAdmin) Duplicate(ctx context.Context, source, target string) error

+ func (n NamespaceAdmin) Export(ctx context.Context, namespace string) (*StreamResponse, error)

+ func (n NamespaceAdmin) Get(ctx context.Context, namespace string) (NamespaceRecord, error)

+ func (n NamespaceAdmin) ImportCSV(ctx context.Context, namespace string, table string, upload ImportOptions) (MutationResult, error)

+ func (n NamespaceAdmin) ImportDatabase(ctx context.Context, namespace string, upload ImportOptions) error

+ func (n NamespaceAdmin) List(ctx context.Context) ([]NamespaceRecord, error)

+ func (n NamespaceAdmin) Update(ctx context.Context, namespace string, config NamespaceConfig) (NamespaceRecord, error)

+ type NamespaceConfig struct

+ BusyTimeout int

+ ForeignKeys *bool

+ JournalMode string

+ MaxDBSize int64

+ QueryTimeout int

+ ReadOnly bool

+ func DefaultNamespaceConfig() NamespaceConfig

+ type NamespaceDefinition struct

+ Config *NamespaceConfig

+ Name string

+ type NamespaceOverview struct

+ Activity struct{ ... }

+ GeneratedAt string

+ Growth ...

+ Health struct{ ... }

+ ReadLatency OverviewLatency

+ Realtime struct{ ... }

+ Schema struct{ ... }

+ Storage struct{ ... }

+ TopOperations []struct{ ... }

+ Window struct{ ... }

+ WriteContention struct{ ... }

+ WriteLatency OverviewLatency

+ type NamespaceRecord struct

+ Config *NamespaceConfig

+ CreatedAt string

+ DBPath string

+ LastActivityAt string

+ Name string

+ Storage *StorageSnapshot

+ type OverviewClient struct

+ func (o OverviewClient) Get(ctx context.Context, window OverviewWindow) (NamespaceOverview, error)

+ type OverviewLatency struct

+ AverageMS float64

+ Count uint64

+ P50MS float64

+ P95MS float64

+ P99MS float64

+ type OverviewWindow string

+ const Window1Hour

+ const Window24Hour

+ const Window30Days

+ const Window7Days

+ type QueryClient struct

+ func (q QueryClient) Batch(ctx context.Context, statements []QueryStatement) (map[string]any, error)

+ func (q QueryClient) Run(ctx context.Context, request QueryRequest) (map[string]any, error)

+ type QueryRequest struct

+ Params []any

+ SQL string

+ Statements []QueryStatement

+ type QueryStatement struct

+ Params []any

+ SQL string

+ type RowsClient struct

+ func (r RowsClient) BulkDelete(ctx context.Context, query map[string][]string, options MutateOptions) (MutationResult, error)

+ func (r RowsClient) BulkUpdate(ctx context.Context, query map[string][]string, payload map[string]any, ...) (MutationResult, error)

+ func (r RowsClient) Delete(ctx context.Context, id int64, options MutateOptions) (MutationResult, error)

+ func (r RowsClient) Get(ctx context.Context, id int64) (map[string]any, error)

+ func (r RowsClient) Insert(ctx context.Context, rows []map[string]any, options MutateOptions) (MutationResult, error)

+ func (r RowsClient) InsertOne(ctx context.Context, row map[string]any, options MutateOptions) (MutationResult, error)

+ func (r RowsClient) List(ctx context.Context, query map[string][]string) (RowsResponse, error)

+ func (r RowsClient) Update(ctx context.Context, id int64, payload map[string]any, options MutateOptions) (MutationResult, error)

+ type RowsResponse struct

+ Data []map[string]any

+ Meta *ListMeta

+ type SSEEvent struct

+ Action string

+ Detail map[string]any

+ Meta json.RawMessage

+ Namespace string

+ Row map[string]any

+ RowCount int

+ RowIDs []any

+ SourceAction string

+ SourceTable string

+ Table string

+ Timestamp string

+ type SchemaClient struct

+ func (s SchemaClient) Delete(ctx context.Context, meta json.RawMessage) error

+ func (s SchemaClient) Get(ctx context.Context) (map[string]any, error)

+ func (s SchemaClient) Update(ctx context.Context, request TableUpdateRequest) error

+ type StorageSnapshot struct

+ AllocatedBytes int64

+ DiskBytes int64

+ UsedBytes int64

+ WALBytes int64

+ type StreamResponse struct

+ Body io.ReadCloser

+ Header http.Header

+ Status int

+ type SubscribeOptions struct

+ Tables []string

+ type TableClient struct

+ Indexes IndexesClient

+ Rows RowsClient

+ Schema SchemaClient

+ func (t *TableClient) Export(ctx context.Context, options TableExportOptions) (*StreamResponse, error)

+ func (t *TableClient) Name() string

+ type TableCreateRequest struct

+ Columns []ColumnDefinition

+ Meta json.RawMessage

+ Metadata json.RawMessage

+ Name string

+ SQL string

+ Type string

+ type TableExportOptions struct

+ BOM bool

+ Query map[string][]string

+ type TableUpdateRequest struct

+ AddColumns []ColumnDefinition

+ DropColumns []string

+ Meta json.RawMessage

+ Metadata json.RawMessage

+ Rename string

+ RenameColumns map[string]string

+ SQL string

+ type TablesClient struct

+ func (t TablesClient) Create(ctx context.Context, request TableCreateRequest) error

+ func (t TablesClient) Delete(ctx context.Context, name string, meta json.RawMessage) error

+ func (t TablesClient) Get(ctx context.Context, name string) (map[string]any, error)

+ func (t TablesClient) List(ctx context.Context) ([]map[string]any, error)

+ func (t TablesClient) Update(ctx context.Context, name string, request TableUpdateRequest) error

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