resource

Dec 17, 2025

Changes in this version

+ func PatchSetDiff(opts ...cmp.Option) func(a, b PatchSetComparer) string

+ func QuerySetDiff(opts ...cmp.Option) func(a, b QuerySetComparer) string

type Client

+ ReadOnlyTransaction func() ReadOnlyTransactionCloser

type MockClient

+ func (c *MockClient) ReadOnlyTransaction() ReadOnlyTransactionCloser

type PatchSet

+ func (p *PatchSet[Resource]) FromStruct(input any, skip ...string) error

+ func (p *PatchSet[Resource]) RegisterOutputOnlyUpdateFunc(field accesstypes.Field, fn FieldDefaultFunc)

+ func (p *PatchSet[Resource]) ToStruct() *Resource

type PatchSetComparer

+ Resource func() accesstypes.Resource

type PostgresClient

+ func (c *PostgresClient) ReadOnlyTransaction() ReadOnlyTransactionCloser

+ type PostgresReadOnlyTransaction struct

+ func (c *PostgresReadOnlyTransaction) Close()

+ func (c *PostgresReadOnlyTransaction) PostgresReadOnlyTransaction() any

+ func (c *PostgresReadOnlyTransaction) SpannerReadOnlyTransaction() spxscan.Querier

type QuerySet

+ func (q *QuerySet[Resource]) ReturnAccessibleFields(b bool) *QuerySet[Resource]

+ type QuerySetComparer interface

+ Fields func() []accesstypes.Field

+ KeySet func() KeySet

+ Resource func() accesstypes.Resource

+ type ReadOnlyTransactionCloser interface

+ Close func()

type SpannerClient

+ func (c *SpannerClient) ReadOnlyTransaction() ReadOnlyTransactionCloser

+ type SpannerReadOnlyTransaction struct

+ func (c *SpannerReadOnlyTransaction) Close()

+ func (c *SpannerReadOnlyTransaction) PostgresReadOnlyTransaction() any

+ func (c *SpannerReadOnlyTransaction) SpannerReadOnlyTransaction() spxscan.Querier

Nov 15, 2025

Changes in this version

+ type MockReader struct

+ func NewMockReader[Resource Resourcer](ctrl *gomock.Controller) *MockReader[Resource]

+ func (m *MockReader[Resource]) DBType() DBType

+ func (m *MockReader[Resource]) EXPECT() *MockReaderMockRecorder[Resource]

+ func (m *MockReader[Resource]) List(ctx context.Context, stmt *Statement) iter.Seq2[*Resource, error]

+ func (m *MockReader[Resource]) Read(ctx context.Context, stmt *Statement) (*Resource, error)

+ type MockReaderMockRecorder struct

+ func (mr *MockReaderMockRecorder[Resource]) DBType() *gomock.Call

+ func (mr *MockReaderMockRecorder[Resource]) List(ctx, stmt any) *gomock.Call

+ func (mr *MockReaderMockRecorder[Resource]) Read(ctx, stmt any) *gomock.Call

Oct 31, 2025

Changes in this version

type ReadWriteTransaction

+ func NewSpannerReadWriteTransaction(txn *spanner.ReadWriteTransaction) ReadWriteTransaction

Oct 29, 2025

Changes in this version

type QuerySet

+ func (q *QuerySet[Resource]) BatchList(ctx context.Context, r Reader[Resource], size int) iter.Seq[iter.Seq2[*Resource, error]]

Oct 27, 2025

Changes in this version

+ func MockIterSeq2[Resource Resourcer](err error, resource ...*Resource) iter.Seq2[*Resource, error]

+ type Client interface

type DBType

+ const MockDBType

type DataChangeEvent

+ Sequence int

+ func (DataChangeEvent) PatchType() PatchType

+ func (DataChangeEvent) Resource() accesstypes.Resource

+ func (d *DataChangeEvent) PrimaryKey() KeySet

+ type Executor interface

+ ExecuteFunc func(ctx context.Context, ...) error

type FilterFieldInfo

+ GOFieldName string

+ JSONFieldName string

+ func (f FilterFieldInfo) ColumnName(dbType DBType) (string, error)

type FilterLexer

+ func (l *FilterLexer) Reset()

type Metadata

+ func (r *Metadata[Resource]) DBFieldCount(dbType DBType) int

+ func (r *Metadata[Resource]) DBFields(dbType DBType) []accesstypes.Field

+ type MockClient struct

+ func NewMockClient(txnMock ReadWriteTransaction, readOnlyMocks, txnReadMocks []any) *MockClient

+ func (c *MockClient) Close()

+ func (c *MockClient) ExecuteFunc(ctx context.Context, ...) error

+ func (c *MockClient) PostgresReadOnlyTransaction() any

+ func (c *MockClient) ReadOnlyMocks() []any

+ func (c *MockClient) SpannerReadOnlyTransaction() spxscan.Querier

+ type MockReadWriteTransaction struct

+ func (c *MockReadWriteTransaction) BufferMap(r PatchSetMetadata, p map[string]any) error

+ func (c *MockReadWriteTransaction) BufferStruct(p PatchSetMetadata) error

+ func (c *MockReadWriteTransaction) DBType() DBType

+ func (c *MockReadWriteTransaction) DataChangeEventIndex(res accesstypes.Resource, rowID string) int

+ func (c *MockReadWriteTransaction) PostgresReadOnlyTransaction() any

+ func (c *MockReadWriteTransaction) SpannerReadOnlyTransaction() spxscan.Querier

+ func (c *MockReadWriteTransaction) TxnReadMocks() []any

+ type PatchSetMetadata interface

+ PatchType func() PatchType

+ PrimaryKey func() KeySet

+ Resource func() accesstypes.Resource

+ type PostgresClient struct

+ func NewPostgresClient(db *pgxpool.Pool) *PostgresClient

+ func (c *PostgresClient) Close()

+ func (c *PostgresClient) ExecuteFunc(_ context.Context, _ func(ctx context.Context, _ ReadWriteTransaction) error) error

+ func (c *PostgresClient) PostgresReadOnlyTransaction() any

+ func (c *PostgresClient) SpannerReadOnlyTransaction() spxscan.Querier

+ type PostgresReadWriteTransaction struct

+ func (c *PostgresReadWriteTransaction) BufferMap(_ PatchSetMetadata, _ map[string]any) error

+ func (c *PostgresReadWriteTransaction) BufferStruct(_ PatchSetMetadata) error

+ func (c *PostgresReadWriteTransaction) DBType() DBType

+ func (c *PostgresReadWriteTransaction) DataChangeEventIndex(res accesstypes.Resource, rowID string) int

+ func (c *PostgresReadWriteTransaction) List(_ context.Context, _ Resourcer, _ []any, _ *Statement) error

+ func (c *PostgresReadWriteTransaction) PostgresReadOnlyTransaction() any

+ func (c *PostgresReadWriteTransaction) Read(_ context.Context, _ Resourcer, _ any, _ *Statement) error

+ func (c *PostgresReadWriteTransaction) SpannerReadOnlyTransaction() spxscan.Querier

+ type PostgresReader struct

+ func (c *PostgresReader[Resource]) DBType() DBType

+ func (c *PostgresReader[Resource]) List(_ context.Context, _ *Statement) iter.Seq2[*Resource, error]

+ func (c *PostgresReader[Resource]) Read(_ context.Context, _ *Statement) (*Resource, error)

type QuerySet

+ func (q *QuerySet[Resource]) FilterAst(dbType DBType) (ExpressionNode, error)

+ func (q *QuerySet[Resource]) List(ctx context.Context, r Reader[Resource]) iter.Seq2[*Resource, error]

+ func (q *QuerySet[Resource]) Read(ctx context.Context, r Reader[Resource]) (*Resource, error)

+ func (q *QuerySet[Resource]) SetFilterParser(parser func(DBType) (ExpressionNode, error))

+ type ReadOnlyTransaction interface

+ PostgresReadOnlyTransaction func() any

+ SpannerReadOnlyTransaction func() spxscan.Querier

+ type ReadWriteTransaction interface

+ BufferMap func(res PatchSetMetadata, patch map[string]any) error

+ BufferStruct func(res PatchSetMetadata) error

+ DBType func() DBType

+ DataChangeEventIndex func(res accesstypes.Resource, rowID string) int

+ func NewMockReadWriteTransaction(mock ReadWriteTransaction, txnReaderMocks ...any) ReadWriteTransaction

+ type Reader interface

+ DBType func() DBType

+ List func(ctx context.Context, stmt *Statement) iter.Seq2[*Resource, error]

+ Read func(ctx context.Context, stmt *Statement) (*Resource, error)

+ func NewReader[Resource Resourcer](txn ReadOnlyTransaction) Reader[Resource]

+ type SpannerClient struct

+ func NewSpannerClient(db *spanner.Client) *SpannerClient

+ func (c *SpannerClient) Close()

+ func (c *SpannerClient) ExecuteFunc(ctx context.Context, ...) error

+ func (c *SpannerClient) PostgresReadOnlyTransaction() any

+ func (c *SpannerClient) SpannerReadOnlyTransaction() spxscan.Querier

+ type SpannerReadWriteTransaction struct

+ func (c *SpannerReadWriteTransaction) BufferMap(r PatchSetMetadata, patch map[string]any) error

+ func (c *SpannerReadWriteTransaction) BufferStruct(patch PatchSetMetadata) error

+ func (c *SpannerReadWriteTransaction) DBType() DBType

+ func (c *SpannerReadWriteTransaction) DataChangeEventIndex(res accesstypes.Resource, rowID string) int

+ func (c *SpannerReadWriteTransaction) PostgresReadOnlyTransaction() any

+ func (c *SpannerReadWriteTransaction) SpannerReadOnlyTransaction() spxscan.Querier

type SpannerReader

+ func (c *SpannerReader[Resource]) DBType() DBType

+ func (c *SpannerReader[Resource]) List(ctx context.Context, stmt *Statement) iter.Seq2[*Resource, error]

+ func (c *SpannerReader[Resource]) Read(ctx context.Context, stmt *Statement) (*Resource, error)

type Statement

+ func (s *Statement) SpannerStatement() spanner.Statement

Oct 10, 2025

Changes in this version

+ type Buffer interface

+ Buffer func(ctx context.Context, txn TxnBuffer, eventSource ...string) error

+ type Committer interface

+ ReadWriteTransaction func(ctx context.Context, ...) (commitTimestamp time.Time, err error)

type PatchSet

+ func (p *PatchSet[Resource]) Apply(ctx context.Context, committer Committer, eventSource ...string) error

+ func (p *PatchSet[Resource]) Buffer(ctx context.Context, txn TxnBuffer, eventSource ...string) error

type PatchType

+ const CreateOrUpdatePatchType

Sep 27, 2025

Changes in this version

+ type FilterFieldInfo struct

+ DbColumnName string

+ FieldType reflect.Type

+ Indexed bool

+ Kind reflect.Kind

+ PII bool

+ type FilterLexer struct

+ func NewFilterLexer(input string) *FilterLexer

+ func (l *FilterLexer) NextToken() (Token, error)

+ type FilterParser struct

+ func NewFilterParser(lexer *FilterLexer, jsonToFieldInfo map[jsonFieldName]FilterFieldInfo) (*FilterParser, error)

+ func (p *FilterParser) Parse() (ExpressionNode, error)

+ type Metadata struct

+ func NewMetadata[Resource Resourcer]() *Metadata[Resource]

+ func (r *Metadata[Resource]) Fields() []accesstypes.Field

+ func (r *Metadata[Resource]) Len() int

+ type Set struct

+ func NewSet[Resource Resourcer, Request any](permissions ...accesstypes.Permission) (*Set[Resource], error)

+ func (r *Set[Resource]) BaseResource() accesstypes.Resource

+ func (r *Set[Resource]) ImmutableFields() map[accesstypes.Tag]struct{}

+ func (r *Set[Resource]) PermissionRequired(fieldName accesstypes.Field, perm accesstypes.Permission) bool

+ func (r *Set[Resource]) Permissions() []accesstypes.Permission

+ func (r *Set[Resource]) Resource(fieldName accesstypes.Field) accesstypes.Resource

+ func (r *Set[Resource]) ResourceMetadata() *Metadata[Resource]

+ func (r *Set[Resource]) TagPermissions() accesstypes.TagPermissions

Sep 24, 2025

Changes in this version

type QuerySet

+ func (q *QuerySet[Resource]) SetOffset(offset *uint64)

Sep 5, 2025

Changes in this version

+ type DefaultsFunc func(ctx context.Context, txn TxnBuffer) error

type PatchSet

+ func (p *PatchSet[Resource]) RegisterDefaultsCreateFunc(fn DefaultsFunc)

+ func (p *PatchSet[Resource]) RegisterDefaultsUpdateFunc(fn DefaultsFunc)

+ func (p *PatchSet[Resource]) RegisterValidateCreateFunc(fn ValidateFunc)

+ func (p *PatchSet[Resource]) RegisterValidateUpdateFunc(fn ValidateFunc)

+ type ValidateFunc func(ctx context.Context, txn TxnBuffer) error

Aug 4, 2025

Changes in this version

type QuerySet

+ func (q *QuerySet[Resource]) SetLimit(limit *uint64)

Jul 22, 2025

Changes in this version

type Operation

+ func (o *Operation) ReqWithPattern(pattern string) (*http.Request, error)

type Option

+ func MatchPrefix() Option

Jun 19, 2025

Changes in this version

type FieldDefaultFunc

+ func DefaultString(v string) FieldDefaultFunc

Jun 18, 2025

Changes in this version

+ func DefaultFalse(_ context.Context, _ TxnBuffer) (any, error)

+ func DefaultTrue(_ context.Context, _ TxnBuffer) (any, error)

Jun 18, 2025

Changes in this version

type FieldInfo

+ Indexed bool

type QueryClause

+ func (qc QueryClause) Validate() error

Jun 17, 2025

Changes in this version

type QuerySet

+ func (q *QuerySet[Resource]) SetFilterAst(ast ExpressionNode)

+ func (q *QuerySet[Resource]) SetSortFields(sortFields []SortField)

+ type Search struct

+ func NewSearch(typ SearchType, values map[SearchKey]string) *Search

type SearchKey

+ func (f SearchKey) String() string

+ type SortDirection string

+ const SortAscending

+ const SortDescending

+ type SortField struct

+ Direction SortDirection

+ Field string

Jun 12, 2025

Changes in this version

+ var ErrExpectedExpression = stderr.New("expected an expression")

+ var ErrExpectedRightParen = stderr.New("expected ')'")

+ var ErrInvalidConditionFormat = stderr.New("invalid condition format")

+ var ErrInvalidFieldName = stderr.New("invalid field name")

+ var ErrInvalidValueFormat = stderr.New("invalid value format for operator")

+ var ErrMissingValue = stderr.New("missing value for operator")

+ var ErrUnexpectedToken = stderr.New("unexpected token")

+ var ErrUnknownOperator = stderr.New("unknown operator")

+ var ErrUnsupportedNodeType = errors.New("unsupported AST node type for SQL generation")

+ var ErrUnsupportedOperator = errors.New("unsupported operator for SQL generation")

+ type Condition struct

+ Field string

+ IsNullOp bool

+ Operator string

+ Value any

+ Values []any

+ type ConditionNode struct

+ Condition Condition

+ func (cn *ConditionNode) String() string

+ type ExpressionNode interface

+ String func() string

+ type FieldInfo struct

+ FieldType reflect.Type

+ Kind reflect.Kind

+ Name string

+ type GroupNode struct

+ Expression ExpressionNode

+ func (gn *GroupNode) String() string

type Ident

+ func (i Ident[T]) IsNotNull() QueryClause

+ func (i Ident[T]) IsNull() QueryClause

+ type Lexer struct

+ func NewLexer(input string) *Lexer

+ func (l *Lexer) NextToken() (Token, error)

+ type LogicalOpNode struct

+ Left ExpressionNode

+ Operator LogicalOperator

+ Right ExpressionNode

+ func (ln *LogicalOpNode) String() string

+ type LogicalOperator string

+ const OperatorAnd

+ const OperatorOr

+ type Parser struct

+ func NewParser(lexer *Lexer, jsonToFieldInfo map[string]FieldInfo) (*Parser, error)

+ func (p *Parser) Parse() (ExpressionNode, error)

+ type PostgreSQLGenerator struct

+ func NewPostgreSQLGenerator() *PostgreSQLGenerator

+ func (g *PostgreSQLGenerator) GenerateSQL(node ExpressionNode) (sqlStr string, params []any, err error)

+ type PostgresStatement struct

+ Params []any

+ SQL string

+ type QueryParam struct

+ Name string

+ Value any

type QuerySet

+ func (q *QuerySet[Resource]) SetParsedFilterAst(ast ExpressionNode)

+ type SQLDialect int

+ const PostgreSQL

+ const Spanner

+ type SpannerGenerator struct

+ func NewSpannerGenerator() *SpannerGenerator

+ func (g *SpannerGenerator) GenerateSQL(node ExpressionNode) (sqlStr string, params map[string]any, err error)

+ type SpannerStatement struct

type Statement

+ PostgreSQLParams []any

+ SQL string

+ SpannerParams map[string]any

+ type Token struct

+ Type TokenType

+ Value string

+ type TokenType int

+ const TokenComma

+ const TokenCondition

+ const TokenEOF

+ const TokenLParen

+ const TokenPipe

+ const TokenRParen

+ func (i TokenType) String() string

May 12, 2025

Changes in this version

+ func CommitTimestamp(_ context.Context, _ TxnBuffer) (any, error)

+ func CommitTimestampPtr(_ context.Context, _ TxnBuffer) (any, error)

type PatchSet

+ func (p *PatchSet[Resource]) RegisterDefaultCreateFunc(field accesstypes.Field, fn FieldDefaultFunc)

+ func (p *PatchSet[Resource]) RegisterDefaultUpdateFunc(field accesstypes.Field, fn FieldDefaultFunc)

May 9, 2025

Changes in this version

type Collection

+ func (s *Collection) ResourceExists(r accesstypes.Resource) bool

May 8, 2025

Changes in this version

+ type StatementWrapper struct

May 8, 2025

Changes in this version

+ type FieldDefaultFunc func(ctx context.Context, txn TxnBuffer) (any, error)

type PatchSet

+ func (p *PatchSet[Resource]) RegisterDefaultFunc(field accesstypes.Field, fn FieldDefaultFunc)

Apr 30, 2025

Changes in this version

type Collection

+ func (s *Collection) AddMethodResource(scope accesstypes.PermissionScope, permission accesstypes.Permission, ...) error

+ type RPCDecoder struct

+ func NewRPCDecoder[Request any](userPermissions func(*http.Request) UserPermissions, ...) (*RPCDecoder[Request], error)

+ func (r *RPCDecoder[Request]) Decode(request *http.Request) (*Request, error)

+ func (s *RPCDecoder[Request]) WithValidator(v ValidatorFunc) *RPCDecoder[Request]

Apr 4, 2025

Changes in this version

+ type CommitBuffer struct

+ func NewCommitBuffer(db TxnFuncRunner, eventSource string, autoCommitSize int) *CommitBuffer

+ func (cb *CommitBuffer) Buffer(ctx context.Context, ps ...SpannerBuffer) error

+ func (cb *CommitBuffer) Commit(ctx context.Context) error

+ type RunnerFunc func(ctx context.Context, txn TxnBuffer) error

+ func (fn RunnerFunc) Execute(ctx context.Context, txn TxnBuffer) error

+ type SpannerCommitter interface

+ ReadWriteTransaction func(ctx context.Context, ...) (commitTimestamp time.Time, err error)

+ type TxnBuffer interface

+ BufferWrite func(ms []*spanner.Mutation) error

+ type TxnFuncRunner interface

+ ExecuteFunc func(ctx context.Context, runnerFn func(ctx context.Context, txn TxnBuffer) error) error

+ type TxnRunner interface

+ Execute func(ctx context.Context, txn TxnBuffer) error

Mar 31, 2025

Changes in this version

+ type Ident struct

+ func NewIdent[T comparable](column string, px PartialQueryClause) Ident[T]

+ func (i Ident[T]) Equal(v ...T) QueryClause

+ func (i Ident[T]) GreaterThan(v T) QueryClause

+ func (i Ident[T]) GreaterThanEq(v T) QueryClause

+ func (i Ident[T]) LessThan(v T) QueryClause

+ func (i Ident[T]) LessThanEq(v T) QueryClause

+ func (i Ident[T]) NotEqual(v ...T) QueryClause

+ type PartialQueryClause struct

+ func NewPartialQueryClause() PartialQueryClause

+ func (p PartialQueryClause) Group(qc QueryClause) QueryClause

+ type QueryClause struct

+ func (x QueryClause) And() PartialQueryClause

+ func (x QueryClause) Or() PartialQueryClause

type QuerySet

+ func (q *QuerySet[Resource]) SetWhereClause(qc QueryClause)

Mar 28, 2025

Changes in this version

+ func CloneRequest(r *http.Request) (*http.Request, error)

+ type BufferWriter interface

+ BufferWrite func(ms []*spanner.Mutation) error

+ type SpannerBuffer interface

+ SpannerBuffer func(ctx context.Context, txn BufferWriter, eventSource ...string) error

Mar 20, 2025

Changes in this version

type Decoder

+ func (d *Decoder[Resource, Request]) DecodeOperation(oper *Operation, userPermissions UserPermissions) (*PatchSet[Resource], error)

+ func (d *Decoder[Resource, Request]) DecodeOperationWithoutPermissions(oper *Operation) (*PatchSet[Resource], error)

+ func (d *Decoder[Resource, Request]) DecodeWithoutPermissions(request *http.Request) (*PatchSet[Resource], error)

type PatchSet

+ func (p *PatchSet[Resource]) EnableUserPermissionEnforcement(rSet *ResourceSet[Resource], userPermissions UserPermissions, ...) *PatchSet[Resource]

type QueryDecoder

+ func (d *QueryDecoder[Resource, Request]) DecodeWithoutPermissions(request *http.Request) (*QuerySet[Resource], error)

type QuerySet

+ func (q *QuerySet[Resource]) EnableUserPermissionEnforcement(rSet *ResourceSet[Resource], userPermissions UserPermissions, ...) *QuerySet[Resource]

+ func (q *QuerySet[Resource]) RequiredPermission() accesstypes.Permission

+ func (q *QuerySet[Resource]) ReturnAccessableFields(b bool) *QuerySet[Resource]

+ type RequestFieldMapper struct

+ func NewRequestFieldMapper(v any) (*RequestFieldMapper, error)

+ func (f *RequestFieldMapper) Fields() []accesstypes.Field

+ func (f *RequestFieldMapper) Len() int

+ func (f *RequestFieldMapper) StructFieldName(jsonTag string) (accesstypes.Field, bool)

type ResourceMetadata

+ func (r *ResourceMetadata[Resource]) Fields() []accesstypes.Field

+ func (r *ResourceMetadata[Resource]) Len() int

type StructDecoder

+ func (d *StructDecoder[Request]) DecodeWithoutPermissions(request *http.Request) (*Request, error)

+ type UserPermissions interface

+ Check func(ctx context.Context, perm accesstypes.Permission, ...) (ok bool, missing []accesstypes.Resource, err error)

+ Domain func() accesstypes.Domain

+ User func() accesstypes.User

Mar 18, 2025

Changes in this version

+ type Filter struct

+ func NewFilter(typ FilterType, values map[FilterKey]string, kinds map[FilterKey]reflect.Kind) *Filter

+ func (f Filter) SpannerStmt() (Statement, error)

type FilterKey

+ func (f FilterKey) String() string

type TypescriptData

+ RPCMethods []accesstypes.Resource

+ ResourcePermissionMap permissionMap

Feb 22, 2025

Changes in this version

+ type FilterKey string

+ type FilterKeys struct

+ func NewFilterKeys[Req any](res Resourcer) (*FilterKeys, error)

+ type FilterSet struct

+ func NewFilterSet(filterTyp FilterType, filterKey FilterKey, filterVal string) *FilterSet

+ type FilterType string

+ const Index

type QuerySet

+ func (q *QuerySet[Resource]) SetFilterParam(filterSet *FilterSet)

Feb 19, 2025

Changes in this version

type QuerySet

+ func (q *QuerySet[Resource]) SetSearchParam(searchSet *SearchSet)

+ type SearchKey string

+ type SearchKeys struct

+ func NewSearchKeys[Req any](res Resourcer) *SearchKeys

+ type SearchSet struct

+ func NewSearchSet(searchTyp SearchType, searchKey SearchKey, searchVal string) *SearchSet

+ type SearchType string

+ const FullText

+ const Ngram

+ const SubString

+ type Statement struct

+ Params map[string]any

+ Sql string

Feb 11, 2025

Changes in this version

+ type Option func(opt options) options

+ func RequireCreatePath() Option

Feb 5, 2025

Changes in this version

+ type Link struct

+ ID ccc.UUID

+ Resource string

+ Text string

+ func (l *Link) DecodeSpanner(val any) error

+ func (l *Link) UnmarshalJSON(data []byte) error

+ func (l Link) EncodeSpanner() (any, error)

+ func (l Link) IsNull() bool

+ func (l Link) MarshalJSON() ([]byte, error)

+ type NullLink struct

+ Link Link

+ Valid bool

+ func (nl *NullLink) DecodeSpanner(val any) error

+ func (nl *NullLink) UnmarshalJSON(data []byte) error

+ func (nl NullLink) EncodeSpanner() (any, error)

+ func (nl NullLink) MarshalJSON() ([]byte, error)

Feb 4, 2025

Changes in this version

type Collection

+ func (c *Collection) TypescriptData() TypescriptData

+ func (s *Collection) Resources() []accesstypes.Resource

+ type TypescriptData struct

+ Domains []accesstypes.PermissionScope

+ Permissions []accesstypes.Permission

+ ResourcePermissions permissionMap

+ ResourceTags map[accesstypes.Resource][]accesstypes.Tag

+ Resources []accesstypes.Resource

Jan 15, 2025

Changes in this version

type PatchSet

+ func (p *PatchSet[Resource]) SpannerApply(ctx context.Context, spanner *spanner.Client, eventSource ...string) error

Dec 18, 2024

Changes in this version

+ func AddResources[Resource Resourcer, Request any](s *Collection, scope accesstypes.PermissionScope, ...) error

+ func Operations(r *http.Request, pattern string) iter.Seq2[*Operation, error]

+ func PatchsetCompare(a, b PatchSetComparer) bool

+ func ProcessEvent(processName string) string

+ func UserEvent(ctx context.Context) string

+ func UserProcessEvent(ctx context.Context, processName string) string

+ type Columns string

+ type Config struct

+ ChangeTrackingTable string

+ DBType DBType

+ TrackChanges bool

+ func (c Config) SetChangeTrackingTable(changeTrackingTable string) Config

+ func (c Config) SetDBType(dbType DBType) Config

+ func (c Config) SetTrackChanges(trackChanges bool) Config

+ type Configurer interface

+ Config func() Config

+ type DBType string

+ const PostgresDBType

+ const SpannerDBType

+ type DataChangeEvent struct

+ ChangeSet string

+ EventSource string

+ EventTime time.Time

+ RowID string

+ TableName accesstypes.Resource

+ type Decoder struct

+ func NewDecoder[Resource Resourcer, Request any](rSet *ResourceSet[Resource, Request]) (*Decoder[Resource, Request], error)

+ func (d *Decoder[Resource, Request]) Decode(request *http.Request) (*PatchSet[Resource], error)

+ func (d *Decoder[Resource, Request]) WithPermissionChecker(domainFromReq DomainFromReq, userFromReq UserFromReq, ...) *DecoderWithPermissionChecker[Resource, Request]

+ func (d *Decoder[Resource, Request]) WithValidator(v ValidatorFunc) *Decoder[Resource, Request]

+ type DecoderWithPermissionChecker struct

+ func (d *DecoderWithPermissionChecker[Resource, Request]) Decode(request *http.Request, perm accesstypes.Permission) (*PatchSet[Resource], error)

+ func (d *DecoderWithPermissionChecker[Resource, Request]) DecodeOperation(oper *Operation) (*PatchSet[Resource], error)

+ func (d *DecoderWithPermissionChecker[Resource, Request]) WithValidator(v ValidatorFunc) *DecoderWithPermissionChecker[Resource, Request]

+ type DiffElem struct

+ New any

+ Old any

+ type DomainFromCtx func(context.Context) accesstypes.Domain

+ type DomainFromReq func(*http.Request) accesstypes.Domain

+ type Operation struct

+ Req *http.Request

+ Type OperationType

+ type OperationType string

+ const OperationCreate

+ const OperationDelete

+ const OperationUpdate

type PatchSet

+ func (p *PatchSet[Resource]) Diff(old any) (map[accesstypes.Field]DiffElem, error)

+ func (p *PatchSet[Resource]) IsSet(field accesstypes.Field) bool

+ func (p *PatchSet[Resource]) PatchType() PatchType

+ func (p *PatchSet[Resource]) PrimaryKey() KeySet

+ func (p *PatchSet[Resource]) Resolve() (map[string]any, error)

+ func (p *PatchSet[Resource]) Resource() accesstypes.Resource

+ func (p *PatchSet[Resource]) SetPatchType(t PatchType) *PatchSet[Resource]

+ func (p *PatchSet[Resource]) SpannerBuffer(ctx context.Context, txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerBufferDelete(ctx context.Context, txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerBufferInsert(txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerBufferInsertOrUpdate(ctx context.Context, txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerBufferUpdate(ctx context.Context, txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerDelete(ctx context.Context, s *spanner.Client, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerInsert(ctx context.Context, s *spanner.Client, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerInsertOrUpdate(ctx context.Context, s *spanner.Client, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerPatch(ctx context.Context, spanner *spanner.Client, eventSource ...string) error

+ func (p *PatchSet[Resource]) SpannerUpdate(ctx context.Context, s *spanner.Client, eventSource ...string) error

+ type PatchSetComparer interface

+ Data func() map[accesstypes.Field]any

+ Fields func() []accesstypes.Field

+ PatchType func() PatchType

+ PrimaryKey func() KeySet

+ type PatchType string

+ const CreatePatchType

+ const DeletePatchType

+ const UpdatePatchType

+ type QueryDecoder struct

+ func NewQueryDecoder[Resource Resourcer, Request any](rSet *ResourceSet[Resource, Request], permissionChecker accesstypes.Enforcer, ...) (*QueryDecoder[Resource, Request], error)

+ func (d *QueryDecoder[Resource, Request]) Decode(request *http.Request) (*QuerySet[Resource], error)

type QuerySet

+ func (q *QuerySet[Resource]) Columns() (Columns, error)

+ func (q *QuerySet[Resource]) Key(field accesstypes.Field) any

+ func (q *QuerySet[Resource]) KeySet() KeySet

+ func (q *QuerySet[Resource]) PostgresStmt() (stmt Stmt, params map[string]any, err error)

+ func (q *QuerySet[Resource]) Resource() accesstypes.Resource

+ func (q *QuerySet[Resource]) SetKey(field accesstypes.Field, value any)

+ func (q *QuerySet[Resource]) SpannerList(ctx context.Context, txn *spanner.ReadOnlyTransaction, dst any) error

+ func (q *QuerySet[Resource]) SpannerRead(ctx context.Context, txn *spanner.ReadOnlyTransaction, dst any) error

+ func (q *QuerySet[Resource]) SpannerStmt() (spanner.Statement, error)

+ func (q *QuerySet[Resource]) Where() (where Where, params map[string]any, err error)

+ type Queryer interface

+ Query func() *QuerySet[T]

+ type ResourceMetadata struct

+ func NewResourceMetadata[Resource Resourcer]() *ResourceMetadata[Resource]

type ResourceSet

+ func (r *ResourceSet[Resource, Request]) ResourceMetadata() *ResourceMetadata[Resource]

type Resourcer

+ DefaultConfig func() Config

+ type SpannerBufferer interface

+ PrimaryKey func() KeySet

+ Resource func() accesstypes.Resource

+ SpannerBuffer func(ctx context.Context, txn *spanner.ReadWriteTransaction, eventSource ...string) error

+ type SpannerLister interface

+ SpannerList func(ctx context.Context, txn *spanner.ReadOnlyTransaction, dst any) error

+ type SpannerReader interface

+ KeySet func() KeySet

+ Resource func() accesstypes.Resource

+ SpannerRead func(ctx context.Context, txn *spanner.ReadOnlyTransaction, dst any) error

+ type Stmt string

+ type StructDecoder struct

+ func NewStructDecoder[Request any]() (*StructDecoder[Request], error)

+ func (d *StructDecoder[Request]) Decode(request *http.Request) (*Request, error)

+ func (d *StructDecoder[Request]) WithPermissionChecker(domainFromReq DomainFromReq, userFromReq UserFromReq, ...) *StructDecoderWithPermissionChecker[Request]

+ func (d *StructDecoder[Request]) WithValidator(v ValidatorFunc) *StructDecoder[Request]

+ type StructDecoderWithPermissionChecker struct

+ func (d *StructDecoderWithPermissionChecker[Request]) Decode(request *http.Request, perm accesstypes.Permission) (*Request, error)

+ func (d *StructDecoderWithPermissionChecker[Request]) WithValidator(v ValidatorFunc) *StructDecoderWithPermissionChecker[Request]

+ type UserFromCtx func(context.Context) accesstypes.User

+ type UserFromReq func(*http.Request) accesstypes.User

+ type ValidatorFunc interface

+ Struct func(s interface{}) error

+ StructPartial func(s interface{}, fields ...string) error

+ type Where string

Dec 5, 2024

Changes in this version

+ type Collection struct

+ func NewCollection() *Collection

+ func (s *Collection) AddResource(scope accesstypes.PermissionScope, permission accesstypes.Permission, ...) error

+ func (s *Collection) AddResources(scope accesstypes.PermissionScope, rSet *ResourceSet) error

+ func (s *Collection) GenerateTypeScript(dst string) error

+ func (s *Collection) IsResourceImmutable(scope accesstypes.PermissionScope, res accesstypes.Resource) bool

+ func (s *Collection) List() map[accesstypes.Permission][]accesstypes.Resource

+ func (s *Collection) Scope(resource accesstypes.Resource) accesstypes.PermissionScope

+ type FieldMapper struct

+ func NewFieldMapper(v any) (*FieldMapper, error)

+ func (f *FieldMapper) Fields() []accesstypes.Field

+ func (f *FieldMapper) Len() int

+ func (f *FieldMapper) StructFieldName(tag string) (accesstypes.Field, bool)

+ type KeyPart struct

+ Key accesstypes.Field

+ Value any

+ type KeySet struct

+ func NewKeySet(key accesstypes.Field, value any) KeySet

+ func (p KeySet) Add(key accesstypes.Field, value any) KeySet

+ func (p KeySet) KeyMap() map[accesstypes.Field]any

+ func (p KeySet) KeySet() spanner.KeySet

+ func (p KeySet) Len() int

+ func (p KeySet) Parts() []KeyPart

+ func (p KeySet) RowID() string

+ func (p KeySet) String() string

+ type PatchSet struct

+ func NewPatchSet() *PatchSet

+ func (p *PatchSet) Data() map[accesstypes.Field]any

+ func (p *PatchSet) Fields() []accesstypes.Field

+ func (p *PatchSet) Get(field accesstypes.Field) any

+ func (p *PatchSet) HasKey() bool

+ func (p *PatchSet) Key(field accesstypes.Field) any

+ func (p *PatchSet) KeySet() KeySet

+ func (p *PatchSet) Len() int

+ func (p *PatchSet) Set(field accesstypes.Field, value any) *PatchSet

+ func (p *PatchSet) SetKey(field accesstypes.Field, value any)

+ type QuerySet struct

+ func NewQuerySet() *QuerySet

+ func (p *QuerySet) AddField(field accesstypes.Field) *QuerySet

+ func (p *QuerySet) Fields() []accesstypes.Field

+ func (p *QuerySet) Len() int

+ type ResourceSet struct

+ func NewResourceSet[Resource Resourcer, Request any](permissions ...accesstypes.Permission) (*ResourceSet, error)

+ func (r *ResourceSet) BaseResource() accesstypes.Resource

+ func (r *ResourceSet) ImmutableFields() map[accesstypes.Tag]struct{}

+ func (r *ResourceSet) Permission() accesstypes.Permission

+ func (r *ResourceSet) PermissionRequired(fieldName accesstypes.Field, perm accesstypes.Permission) bool

+ func (r *ResourceSet) Permissions() []accesstypes.Permission

+ func (r *ResourceSet) Resource(fieldName accesstypes.Field) accesstypes.Resource

+ func (r *ResourceSet) TagPermissions() accesstypes.TagPermissions

+ type Resourcer interface

+ Resource func() accesstypes.Resource

+ type TSGenerator struct

+ Domains []accesstypes.PermissionScope

+ Permissions []accesstypes.Permission

+ ResourcePermissions permissionMap

+ ResourceTags map[accesstypes.Resource][]accesstypes.Tag

+ Resources []accesstypes.Resource