Versions in this module Expand all Collapse all v1 v1.15.1 Jun 9, 2025 Changes in this version + func NewPostgreSQLQueryStateStore(logger logger.Logger, opts Options) state.Store + func NewPostgreSQLStateStore(logger logger.Logger, opts Options) state.Store + type MigrateOptions struct + Logger logger.Logger + MetadataTableName string + StateTableName string + type Options struct + ETagColumn string + EnableAWSIAM bool + EnableAzureAD bool + MigrateFn func(context.Context, pginterfaces.PGXPoolConn, MigrateOptions) error + SetQueryFn func(*state.SetRequest, SetQueryOptions) string + type PostgreSQL struct + func (p *PostgreSQL) BulkGet(parentCtx context.Context, req []state.GetRequest, _ state.BulkGetOpts) ([]state.BulkGetResponse, error) + func (p *PostgreSQL) CleanupExpired() error + func (p *PostgreSQL) Close() error + func (p *PostgreSQL) Delete(ctx context.Context, req *state.DeleteRequest) (err error) + func (p *PostgreSQL) Features() []state.Feature + func (p *PostgreSQL) Get(parentCtx context.Context, req *state.GetRequest) (*state.GetResponse, error) + func (p *PostgreSQL) GetCleanupInterval() *time.Duration + func (p *PostgreSQL) GetComponentMetadata() (metadataInfo metadata.MetadataMap) + func (p *PostgreSQL) GetDB() *pgxpool.Pool + func (p *PostgreSQL) Init(ctx context.Context, meta state.Metadata) error + func (p *PostgreSQL) Multi(parentCtx context.Context, request *state.TransactionalStateRequest) error + func (p *PostgreSQL) Set(ctx context.Context, req *state.SetRequest) error + type PostgreSQLQuery struct + func (p *PostgreSQLQuery) Features() []state.Feature + func (p *PostgreSQLQuery) Query(parentCtx context.Context, req *state.QueryRequest) (*state.QueryResponse, error) + type Query struct + func (q *Query) Finalize(filters string, qq *query.Query) error + func (q *Query) VisitAND(f *query.AND) (string, error) + func (q *Query) VisitEQ(f *query.EQ) (string, error) + func (q *Query) VisitGT(f *query.GT) (string, error) + func (q *Query) VisitGTE(f *query.GTE) (string, error) + func (q *Query) VisitIN(f *query.IN) (string, error) + func (q *Query) VisitLT(f *query.LT) (string, error) + func (q *Query) VisitLTE(f *query.LTE) (string, error) + func (q *Query) VisitNEQ(f *query.NEQ) (string, error) + func (q *Query) VisitOR(f *query.OR) (string, error) + type SetQueryOptions struct + ExpireDateValue string + TableName string
Go to main page