Versions in this module Expand all Collapse all v1 v1.9.0 Jun 12, 2019 Changes in this version + type AuthTransactionServer interface + AuthorizeInTransaction func(*TransactionContext, *auth.AuthorizeRequest) (*auth.AuthorizeResponse, error) + GetACLInTransaction func(*TransactionContext, *auth.GetACLRequest) (*auth.GetACLResponse, error) + GetScopeInTransaction func(*TransactionContext, *auth.GetScopeRequest) (*auth.GetScopeResponse, error) + SetACLInTransaction func(*TransactionContext, *auth.SetACLRequest) (*auth.SetACLResponse, error) + SetScopeInTransaction func(*TransactionContext, *auth.SetScopeRequest) (*auth.SetScopeResponse, error) + type AuthWrites interface + SetACL func(*auth.SetACLRequest) (*auth.SetACLResponse, error) + SetScope func(*auth.SetScopeRequest) (*auth.SetScopeResponse, error) + type PfsPropagater interface + PropagateCommit func(branch *pfs.Branch, isNewCommit bool) error + Run func() error + type PfsTransactionServer interface + CreateBranchInTransaction func(*TransactionContext, *pfs.CreateBranchRequest) error + CreateRepoInTransaction func(*TransactionContext, *pfs.CreateRepoRequest) error + DeleteBranchInTransaction func(*TransactionContext, *pfs.DeleteBranchRequest) error + DeleteCommitInTransaction func(*TransactionContext, *pfs.DeleteCommitRequest) error + DeleteRepoInTransaction func(*TransactionContext, *pfs.DeleteRepoRequest) error + FinishCommitInTransaction func(*TransactionContext, *pfs.FinishCommitRequest) error + InspectRepoInTransaction func(*TransactionContext, *pfs.InspectRepoRequest) (*pfs.RepoInfo, error) + NewPropagater func(col.STM) PfsPropagater + StartCommitInTransaction func(*TransactionContext, *pfs.StartCommitRequest, *pfs.Commit) (*pfs.Commit, error) + type PfsWrites interface + CreateBranch func(*pfs.CreateBranchRequest) error + CreateRepo func(*pfs.CreateRepoRequest) error + DeleteBranch func(*pfs.DeleteBranchRequest) error + DeleteCommit func(*pfs.DeleteCommitRequest) error + DeleteRepo func(*pfs.DeleteRepoRequest) error + FinishCommit func(*pfs.FinishCommitRequest) error + StartCommit func(*pfs.StartCommitRequest, *pfs.Commit) (*pfs.Commit, error) + type Transaction interface + func NewDirectTransaction(txnCtx *TransactionContext) Transaction + type TransactionContext struct + Client *client.APIClient + ClientContext context.Context + Stm col.STM + func (t *TransactionContext) Auth() AuthTransactionServer + func (t *TransactionContext) Pfs() PfsTransactionServer + func (t *TransactionContext) PropagateCommit(branch *pfs.Branch, isNewCommit bool) error + type TransactionEnv struct + func (env *TransactionEnv) Initialize(serviceEnv *serviceenv.ServiceEnv, txnServer TransactionServer, ...) + func (env *TransactionEnv) WithReadContext(ctx context.Context, cb func(*TransactionContext) error) error + func (env *TransactionEnv) WithTransaction(ctx context.Context, cb func(Transaction) error) error + func (env *TransactionEnv) WithWriteContext(ctx context.Context, cb func(*TransactionContext) error) error + type TransactionServer interface + AppendRequest func(context.Context, *transaction.Transaction, *transaction.TransactionRequest) (*transaction.TransactionResponse, error) v1.9.0-1ff617394086e2ac29d786b2c19a63288572383a Jun 6, 2019