tests

package
v0.7.5 Latest Latest
Warning

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

 Go to latest Published: May 21, 2024 License: MIT Imports: 31 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 

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)

func (Case) String 

func (c Case) String() string

type ClientIdentityReceiver 

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

func (*ClientIdentityReceiver) Receive 

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

type ErroringReceiver 

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

func (*ErroringReceiver) Receive 

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

type FailSendCompletedSender 

type FailSendCompletedSender struct {
	*endpoint.Sender
}

func (*FailSendCompletedSender) SendCompleted 

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

type NeverEndingSender 

type NeverEndingSender struct {
	*endpoint.Sender
}

func (*NeverEndingSender) Send 

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

func (*NeverEndingSender) SendDry 

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

type PartialSender 

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

func (*PartialSender) Send 

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.