tests

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 10, 2023 License: MIT Imports: 32 Imported by: 0

Documentation

Index

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 added in v0.3.0 

func CreateReplicationCursor(ctx *platformtest.Context)

func GetNonexistent 

func GetNonexistent(ctx *platformtest.Context)

func HoldsWork added in v0.3.0 

func HoldsWork(ctx *platformtest.Context)

func IdempotentBookmark added in v0.3.0 

func IdempotentBookmark(ctx *platformtest.Context)

func IdempotentDestroy added in v0.3.0 

func IdempotentDestroy(ctx *platformtest.Context)

func IdempotentHold added in v0.3.0 

func IdempotentHold(ctx *platformtest.Context)

func ListFilesystemVersionsFilesystemNotExist added in v0.3.0 

func ListFilesystemVersionsFilesystemNotExist(t *platformtest.Context)

func ListFilesystemVersionsTypeFilteringAndPrefix added in v0.3.0 

func ListFilesystemVersionsTypeFilteringAndPrefix(t *platformtest.Context)

func ListFilesystemVersionsUserrefs added in v0.3.0 

func ListFilesystemVersionsUserrefs(t *platformtest.Context)

func ListFilesystemVersionsZeroExistIsNotAnError added in v0.3.0 

func ListFilesystemVersionsZeroExistIsNotAnError(t *platformtest.Context)

func ListFilesystemsNoFilter added in v0.3.0 

func ListFilesystemsNoFilter(t *platformtest.Context)

func ReceiveForceIntoEncryptedErr added in v0.3.0 

func ReceiveForceIntoEncryptedErr(ctx *platformtest.Context)

func ReceiveForceRollbackWorksUnencrypted added in v0.3.0 

func ReceiveForceRollbackWorksUnencrypted(ctx *platformtest.Context)

func ReplicationFailingInitialParentProhibitsChildReplication added in v0.3.0 

func ReplicationFailingInitialParentProhibitsChildReplication(ctx *platformtest.Context)

func ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication added in v0.3.0 

func ReplicationIncrementalCleansUpStaleAbstractionsWithCacheOnSecondReplication(ctx *platformtest.Context)

func ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication added in v0.3.0 

func ReplicationIncrementalCleansUpStaleAbstractionsWithoutCacheOnSecondReplication(ctx *platformtest.Context)

func ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist added in v0.3.0 

func ReplicationIncrementalDestroysStepHoldsIffIncrementalStepHoldsAreDisabledButStepHoldsExist(ctx *platformtest.Context)

func ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly added in v0.6.1 

func ReplicationIncrementalHandlesFromVersionEqTentativeCursorCorrectly(ctx *platformtest.Context)

func ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed added in v0.3.0 

func ReplicationIncrementalIsPossibleIfCommonSnapshotIsDestroyed(ctx *platformtest.Context)

func ReplicationInitialAll added in v0.6.0 

func ReplicationInitialAll(ctx *platformtest.Context)

func ReplicationInitialFail added in v0.6.0 

func ReplicationInitialFail(ctx *platformtest.Context)

func ReplicationInitialMostRecent added in v0.6.0 

func ReplicationInitialMostRecent(ctx *platformtest.Context)

func ReplicationIsResumableFullSend__both_GuaranteeResumability added in v0.3.0 

func ReplicationIsResumableFullSend__both_GuaranteeResumability(ctx *platformtest.Context)

func ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication added in v0.3.0 

func ReplicationIsResumableFullSend__initial_GuaranteeIncrementalReplication_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)

func ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication added in v0.3.0 

func ReplicationIsResumableFullSend__initial_GuaranteeResumability_incremental_GuaranteeIncrementalReplication(ctx *platformtest.Context)

func ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit added in v0.5.0 

func ReplicationPlaceholderEncryption__EncryptOnReceiverUseCase__WorksIfConfiguredWithInherit(ctx *platformtest.Context)

func ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder added in v0.5.0 

func ReplicationPlaceholderEncryption__UnspecifiedIsOkForClientIdentityPlaceholder(ctx *platformtest.Context)

func ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders added in v0.5.0 

func ReplicationPlaceholderEncryption__UnspecifiedLeadsToFailureAtRuntimeWhenCreatingPlaceholders(ctx *platformtest.Context)

func ReplicationPropertyReplicationWorks added in v0.4.0 

func ReplicationPropertyReplicationWorks(ctx *platformtest.Context)

func ReplicationReceiverErrorWhileStillSending added in v0.3.0 

func ReplicationReceiverErrorWhileStillSending(ctx *platformtest.Context)

func ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication added in v0.3.0 

func ReplicationStepCompletedLostBehavior__GuaranteeIncrementalReplication(ctx *platformtest.Context)

func ReplicationStepCompletedLostBehavior__GuaranteeResumability added in v0.3.0 

func ReplicationStepCompletedLostBehavior__GuaranteeResumability(ctx *platformtest.Context)

func ResumableRecvAndTokenHandling added in v0.3.0 

func ResumableRecvAndTokenHandling(ctx *platformtest.Context)

func ResumeTokenParsing added in v0.3.0 

func ResumeTokenParsing(ctx *platformtest.Context)

func SendArgsValidationEE_EncryptionAndRaw added in v0.6.0 

func SendArgsValidationEE_EncryptionAndRaw(ctx *platformtest.Context)

func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false added in v0.3.1 

func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_false(ctx *platformtest.Context)

func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true added in v0.3.1 

func SendArgsValidationEncryptedSendOfUnencryptedDatasetForbidden__EncryptionSupported_true(ctx *platformtest.Context)

func SendArgsValidationResumeTokenDifferentFilesystemForbidden added in v0.3.0 

func SendArgsValidationResumeTokenDifferentFilesystemForbidden(ctx *platformtest.Context)

func SendArgsValidationResumeTokenEncryptionMismatchForbidden added in v0.3.0 

func SendArgsValidationResumeTokenEncryptionMismatchForbidden(ctx *platformtest.Context)

func SendStreamCloseAfterBlockedOnPipeWrite added in v0.5.0 

func SendStreamCloseAfterBlockedOnPipeWrite(ctx *platformtest.Context)

func SendStreamCloseAfterEOFRead added in v0.5.0 

func SendStreamCloseAfterEOFRead(ctx *platformtest.Context)

func SendStreamMultipleCloseAfterEOF added in v0.5.0 

func SendStreamMultipleCloseAfterEOF(ctx *platformtest.Context)

func SendStreamMultipleCloseBeforeEOF added in v0.5.0 

func SendStreamMultipleCloseBeforeEOF(ctx *platformtest.Context)

func SendStreamNonEOFReadErrorHandling added in v0.5.0 

func SendStreamNonEOFReadErrorHandling(ctx *platformtest.Context)

func UndestroyableSnapshotParsing 

func UndestroyableSnapshotParsing(t *platformtest.Context)

Types

type Case 

type Case func(*platformtest.Context)

func (Case) String 

func (c Case) String() string

type ClientIdentityReceiver added in v0.5.0 

type ClientIdentityReceiver struct {
	*endpoint.Receiver
	// contains filtered or unexported fields
}

func (*ClientIdentityReceiver) Receive added in v0.5.0 

func (r *ClientIdentityReceiver) Receive(ctx context.Context, req *pdu.ReceiveReq, stream io.ReadCloser) (*pdu.ReceiveRes, error)

type ErroringReceiver added in v0.3.0 

type ErroringReceiver struct {
	*endpoint.Receiver
	// contains filtered or unexported fields
}

func (*ErroringReceiver) Receive added in v0.3.0 

func (r *ErroringReceiver) Receive(ctx context.Context, req *pdu.ReceiveReq, stream io.ReadCloser) (*pdu.ReceiveRes, error)

type FailSendCompletedSender added in v0.3.0 

type FailSendCompletedSender struct {
	*endpoint.Sender
}

func (*FailSendCompletedSender) SendCompleted added in v0.3.0 

func (p *FailSendCompletedSender) SendCompleted(ctx context.Context, r *pdu.SendCompletedReq) (*pdu.SendCompletedRes, error)

type NeverEndingSender added in v0.3.0 

type NeverEndingSender struct {
	*endpoint.Sender
}

func (*NeverEndingSender) Send added in v0.3.0 

func (s *NeverEndingSender) Send(ctx context.Context, req *pdu.SendReq) (r *pdu.SendRes, stream io.ReadCloser, _ error)

func (*NeverEndingSender) SendDry added in v0.5.0 

func (s *NeverEndingSender) SendDry(ctx context.Context, req *pdu.SendReq) (r *pdu.SendRes, err error)

type PartialSender added in v0.3.0 

type PartialSender struct {
	*endpoint.Sender
	// contains filtered or unexported fields
}

func (*PartialSender) Send added in v0.3.0 

func (s *PartialSender) Send(ctx context.Context, r *pdu.SendReq) (r1 *pdu.SendRes, r2 io.ReadCloser, r3 error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.