traffic

type ClientReport struct {
	ClientId         int
	OperationHistory model.History
	Watch            []WatchResponse
}

type Config struct {
	Name string
	// contains filtered or unexported fields
}

type KubernetesRequestType string

type RecordingClient struct {
	// contains filtered or unexported fields
}

type TimedWatchEvent struct {
	WatchEvent
	Time time.Duration
}

type Traffic interface {
	Run(ctx context.Context, c *RecordingClient, limiter *rate.Limiter, ids identity.Provider, lm identity.LeaseIdStorage, finish <-chan struct{})
}

type WatchEvent struct {
	Op       model.EtcdOperation
	Revision int64
}

type WatchResponse struct {
	Events           []WatchEvent
	IsProgressNotify bool
	Revision         int64
	Time             time.Duration
}