Documentation ¶
Index ¶
- Constants
- Variables
- func BatchDestroy(ctx *platformtest.Context)
- func CreateReplicationCursor(ctx *platformtest.Context)
- func GetNonexistent(ctx *platformtest.Context)
- func HoldsWork(ctx *platformtest.Context)
- func IdempotentBookmark(ctx *platformtest.Context)
- func IdempotentDestroy(ctx *platformtest.Context)
- func IdempotentHold(ctx *platformtest.Context)
- func ListFilesystemVersionsFilesystemNotExist(t *platformtest.Context)
- func ListFilesystemVersionsTypeFilteringAndPrefix(t *platformtest.Context)
- func ListFilesystemVersionsUserrefs(t *platformtest.Context)
- func ListFilesystemVersionsZeroExistIsNotAnError(t *platformtest.Context)
- func ListFilesystemsNoFilter(t *platformtest.Context)
- func ReceiveForceIntoEncryptedErr(ctx *platformtest.Context)
- func ReceiveForceRollbackWorksUnencrypted(ctx *platformtest.Context)
- func ReplicationFailingInitialParentProhibitsChildReplication(ctx *platformtest.Context)
- func ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication(ctx *platformtest.Context)
- func ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication(ctx *platformtest.Context)
- func ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist(ctx *platformtest.Context)
- func ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly(ctx *platformtest.Context)
- func ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed(ctx *platformtest.Context)
- func ReplicationInitialAll(ctx *platformtest.Context)
- func ReplicationInitialFail(ctx *platformtest.Context)
- func ReplicationInitialMostRecent(ctx *platformtest.Context)
- func ReplicationIsResumableFullSend__both_GuaranteeResumability(ctx *platformtest.Context)
- func ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)
- func ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)
- func ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit(ctx *platformtest.Context)
- func ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder(ctx *platformtest.Context)
- func ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders(ctx *platformtest.Context)
- func ReplicationPropertyReplicationWorks(ctx *platformtest.Context)
- func ReplicationReceiverErrorWhileStillSending(ctx *platformtest.Context)
- func ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication(ctx *platformtest.Context)
- func ReplicationStepCompletedLostBehavior__GuaranteeResumability(ctx *platformtest.Context)
- func ResumableRecvAndTokenHandling(ctx *platformtest.Context)
- func ResumeTokenParsing(ctx *platformtest.Context)
- func SendArgsValidationEE_EncryptionAndRaw(ctx *platformtest.Context)
- func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false(ctx *platformtest.Context)
- func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true(ctx *platformtest.Context)
- func SendArgsValidationResumeTokenDifferentFilesystemForbidden(ctx *platformtest.Context)
- func SendArgsValidationResumeTokenEncryptionMismatchForbidden(ctx *platformtest.Context)
- func SendStreamCloseAfterBlockedOnPipeWrite(ctx *platformtest.Context)
- func SendStreamCloseAfterEOFRead(ctx *platformtest.Context)
- func SendStreamMultipleCloseAfterEOF(ctx *platformtest.Context)
- func SendStreamMultipleCloseBeforeEOF(ctx *platformtest.Context)
- func SendStreamNonEOFReadErrorHandling(ctx *platformtest.Context)
- func UndestroyableSnapshotParsing(t *platformtest.Context)
- type Case
- type ClientIdentityReceiver
- type ErroringReceiver
- type FailSendCompletedSender
- type NeverEndingSender
- type PartialSender
Constants ¶
View Source
const ( ValidationAccepts sendArgsValidationEndToEndTestOutcome = "accept" ValidationRejects sendArgsValidationEndToEndTestOutcome = "rejects" )
Variables ¶
View Source
var Cases = []Case{BatchDestroy, CreateReplicationCursor, GetNonexistent, HoldsWork, IdempotentBookmark, IdempotentDestroy, IdempotentHold, ListFilesystemVersionsFilesystemNotExist, ListFilesystemVersionsTypeFilteringAndPrefix, ListFilesystemVersionsUserrefs, ListFilesystemVersionsZeroExistIsNotAnError, ListFilesystemsNoFilter, ReceiveForceIntoEncryptedErr, ReceiveForceRollbackWorksUnencrypted, ReplicationFailingInitialParentProhibitsChildReplication, ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication, ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication, ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist, ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly, ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed, ReplicationInitialAll, ReplicationInitialFail, ReplicationInitialMostRecent, ReplicationIsResumableFullSend__both_GuaranteeResumability, ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication, ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication, ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit, ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder, ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders, ReplicationPropertyReplicationWorks, ReplicationReceiverErrorWhileStillSending, ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication, ReplicationStepCompletedLostBehavior__GuaranteeResumability, ResumableRecvAndTokenHandling, ResumeTokenParsing, SendArgsValidationEE_EncryptionAndRaw, SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false, SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true, SendArgsValidationResumeTokenDifferentFilesystemForbidden, SendArgsValidationResumeTokenEncryptionMismatchForbidden, SendStreamCloseAfterBlockedOnPipeWrite, SendStreamCloseAfterEOFRead, SendStreamMultipleCloseAfterEOF, SendStreamMultipleCloseBeforeEOF, SendStreamNonEOFReadErrorHandling, UndestroyableSnapshotParsing, }
Functions ¶
func BatchDestroy ¶
func BatchDestroy(ctx *platformtest.Context)
func CreateReplicationCursor ¶
func CreateReplicationCursor(ctx *platformtest.Context)
func GetNonexistent ¶
func GetNonexistent(ctx *platformtest.Context)
func HoldsWork ¶
func HoldsWork(ctx *platformtest.Context)
func IdempotentBookmark ¶
func IdempotentBookmark(ctx *platformtest.Context)
func IdempotentDestroy ¶
func IdempotentDestroy(ctx *platformtest.Context)
func IdempotentHold ¶
func IdempotentHold(ctx *platformtest.Context)
func ListFilesystemVersionsFilesystemNotExist ¶
func ListFilesystemVersionsFilesystemNotExist(t *platformtest.Context)
func ListFilesystemVersionsTypeFilteringAndPrefix ¶
func ListFilesystemVersionsTypeFilteringAndPrefix(t *platformtest.Context)
func ListFilesystemVersionsUserrefs ¶
func ListFilesystemVersionsUserrefs(t *platformtest.Context)
func ListFilesystemVersionsZeroExistIsNotAnError ¶
func ListFilesystemVersionsZeroExistIsNotAnError(t *platformtest.Context)
func ListFilesystemsNoFilter ¶
func ListFilesystemsNoFilter(t *platformtest.Context)
func ReceiveForceIntoEncryptedErr ¶
func ReceiveForceIntoEncryptedErr(ctx *platformtest.Context)
func ReceiveForceRollbackWorksUnencrypted ¶
func ReceiveForceRollbackWorksUnencrypted(ctx *platformtest.Context)
func ReplicationFailingInitialParentProhibitsChildReplication ¶
func ReplicationFailingInitialParentProhibitsChildReplication(ctx *platformtest.Context)
func ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication ¶
func ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication(ctx *platformtest.Context)
func ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication ¶
func ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication(ctx *platformtest.Context)
func ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist ¶
func ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist(ctx *platformtest.Context)
func ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly ¶
func ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly(ctx *platformtest.Context)
func ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed ¶
func ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed(ctx *platformtest.Context)
func ReplicationInitialAll ¶
func ReplicationInitialAll(ctx *platformtest.Context)
func ReplicationInitialFail ¶
func ReplicationInitialFail(ctx *platformtest.Context)
func ReplicationInitialMostRecent ¶
func ReplicationInitialMostRecent(ctx *platformtest.Context)
func ReplicationIsResumableFullSend__both_GuaranteeResumability ¶
func ReplicationIsResumableFullSend__both_GuaranteeResumability(ctx *platformtest.Context)
func ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication ¶
func ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)
func ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication ¶
func ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)
func ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit ¶
func ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit(ctx *platformtest.Context)
func ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder ¶
func ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder(ctx *platformtest.Context)
func ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders ¶
func ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders(ctx *platformtest.Context)
func ReplicationPropertyReplicationWorks ¶
func ReplicationPropertyReplicationWorks(ctx *platformtest.Context)
func ReplicationReceiverErrorWhileStillSending ¶
func ReplicationReceiverErrorWhileStillSending(ctx *platformtest.Context)
func ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication ¶
func ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication(ctx *platformtest.Context)
func ReplicationStepCompletedLostBehavior__GuaranteeResumability ¶
func ReplicationStepCompletedLostBehavior__GuaranteeResumability(ctx *platformtest.Context)
func ResumableRecvAndTokenHandling ¶
func ResumableRecvAndTokenHandling(ctx *platformtest.Context)
func ResumeTokenParsing ¶
func ResumeTokenParsing(ctx *platformtest.Context)
func SendArgsValidationEE_EncryptionAndRaw ¶
func SendArgsValidationEE_EncryptionAndRaw(ctx *platformtest.Context)
func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false ¶
func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false(ctx *platformtest.Context)
func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true ¶
func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true(ctx *platformtest.Context)
func SendArgsValidationResumeTokenDifferentFilesystemForbidden ¶
func SendArgsValidationResumeTokenDifferentFilesystemForbidden(ctx *platformtest.Context)
func SendArgsValidationResumeTokenEncryptionMismatchForbidden ¶
func SendArgsValidationResumeTokenEncryptionMismatchForbidden(ctx *platformtest.Context)
func SendStreamCloseAfterBlockedOnPipeWrite ¶
func SendStreamCloseAfterBlockedOnPipeWrite(ctx *platformtest.Context)
func SendStreamCloseAfterEOFRead ¶
func SendStreamCloseAfterEOFRead(ctx *platformtest.Context)
func SendStreamMultipleCloseAfterEOF ¶
func SendStreamMultipleCloseAfterEOF(ctx *platformtest.Context)
func SendStreamMultipleCloseBeforeEOF ¶
func SendStreamMultipleCloseBeforeEOF(ctx *platformtest.Context)
func SendStreamNonEOFReadErrorHandling ¶
func SendStreamNonEOFReadErrorHandling(ctx *platformtest.Context)
func UndestroyableSnapshotParsing ¶
func UndestroyableSnapshotParsing(t *platformtest.Context)
Types ¶
type Case ¶
type Case func(*platformtest.Context)
type ClientIdentityReceiver ¶
func (*ClientIdentityReceiver) Receive ¶
func (r *ClientIdentityReceiver) Receive(ctx context.Context, req *pdu.ReceiveReq, stream io.ReadCloser) (*pdu.ReceiveRes, error)
type ErroringReceiver ¶
func (*ErroringReceiver) Receive ¶
func (r *ErroringReceiver) Receive(ctx context.Context, req *pdu.ReceiveReq, stream io.ReadCloser) (*pdu.ReceiveRes, error)
type FailSendCompletedSender ¶
func (*FailSendCompletedSender) SendCompleted ¶
func (p *FailSendCompletedSender) SendCompleted(ctx context.Context, r *pdu.SendCompletedReq) (*pdu.SendCompletedRes, error)
type NeverEndingSender ¶
Source Files ¶
- batchDestroy.go
- generated_cases.go
- getNonexistent.go
- helpers.go
- holds.go
- idempotentBookmark.go
- idempotentDestroy.go
- idempotentHold.go
- listFilesystemVersions.go
- listFilesystems.go
- recvForceIntoEncryptedErr.go
- recvRollback.go
- replication.go
- replicationCursor.go
- resumableRecvAndTokenHandling.go
- resumeTokenParsing.go
- sendArgsValidation.go
- sendStream.go
- tests.go
- undestroyableSnapshotParsing.go
Click to show internal directories.
Click to hide internal directories.