storageutils

Documentation

Index

• func WrapFilterForReplayProtection(filter kvserverbase.ReplicaCommandFilter) kvserverbase.ReplicaCommandFilter
• type ReplayProtectionFilterWrapper

Functions

func WrapFilterForReplayProtection

func WrapFilterForReplayProtection(
	filter kvserverbase.ReplicaCommandFilter,
) kvserverbase.ReplicaCommandFilter

WrapFilterForReplayProtection wraps a filter into another one that adds Raft replay protection.

Types

type ReplayProtectionFilterWrapper

type ReplayProtectionFilterWrapper struct {
	syncutil.Mutex
	// contains filtered or unexported fields
}

ReplayProtectionFilterWrapper wraps a CommandFilter and assures protection from Raft replays.