NewRaftLoggerZap converts "*zap.Logger" to "raft.Logger".

Publish is a mock publish method.

RoundTripProtobufTestForScheme is convenient to call if you already have a scheme and want to make sure that its well-formed

RoundTripTestForScheme is convenient to call if you already have a scheme and want to make sure that its well-formed

RoundTripTypesWithoutProtobuf applies the round-trip test to all round-trippable Kinds in the scheme. It will skip all the GroupVersionKinds in the s

Funcs includes fuzzing funcs for knative.dev/serving types For other examples see https://github.com/kubernetes/apimachinery/blob/master/pkg/apis/met

Subscribe is a mock subscribe method.

TestRoundTrip checks the conversion to go-openapi types. internal -> go-openapi -> JSON -> external -> internal. Similar to https://github.com/kuberne

Helper to check access with expectation and debug tracking

Helper to check access with contextual tuples and debug tracking

callDemotePrimary implements a wrapper for fuzzing DemotePrimary

callExecuteFetchAsApp implements a wrapper for fuzzing ExecuteFetchAsApp

callGetReplicas implements a wrapper for fuzzing GetReplicas

callInitPrimary implements a wrapper for fuzzing InitPrimary

callInitReplica implements a wrapper for fuzzing InitReplica

callPopulateReparentJournal implements a wrapper for fuzzing PopulateReparentJournal

callPrimaryPosition implements a wrapper for fuzzing PrimaryPosition

callPrimaryStatus implements a wrapper for fuzzing PrimaryStatus

callPromoteReplica implements a wrapper for fuzzing PromoteReplica

callReplicaWasPromoted implements a wrapper for fuzzing ReplicaWasPromoted

callReplicaWasRestarted implements a wrapper for fuzzing ReplicaWasRestarted

callReplicationStatus implements a wrapper for fuzzing ReplicationStatus

callResetReplication implements a wrapper for fuzzing ResetReplication

callSetReplicationSource implements a wrapper for fuzzing SetReplicationSource

callStartReplication implements a wrapper for fuzzing StartReplication

callStopReplication implements a wrapper for fuzzing StopReplication

callStopReplicationAndGetStatus implements a wrapper for fuzzing StopReplicationAndGetStatus

callUndoDemotePrimary implements a wrapper for fuzzing UndoDemotePrimary

callVReplicationExec implements a wrapper for fuzzing VReplicationExec

callVExec implements a wrapper for fuzzing VExec *func (fs *fuzzStore) callVExec() error { tablet, err := fs.getTablet() if err != nil { return er

callWaitForPosition implements a wrapper for fuzzing WaitForPosition

TODO: catchOperatorPanics will be obsolete if validateWorkflowForClient is proven to avoid panics from fake.NewSimpleDynamicClient(). See validateWork

catchPanics recovers from expected MustUnmarshal panics.

We ignore these panics, as they don't represent real bugs.

Helper functions

computePublicReachability determines which objects are publicly accessible. An object is publicly accessible if it has user:* OR has a chain edge to a

consumeRest returns all remaining bytes.

contains checks if a string is present in a string slice

Taken from https://github.com/kubernetes/client-go/blob/master/dynamic/fake/simple.go#L457 to support validateWorkflowForClient