hammer

Documentation

Overview

Package hammer sends multiple requests to Key Transparency at the same time.

Index

• type CallOptions
• type Config
• type DialFunc
• type Hammer
  • func New(ctx context.Context, dial DialFunc, callOptions CallOptions, ...) (*Hammer, error)
  • func (h *Hammer) Run(ctx context.Context, numWorkers int, c Config) error
• type ReqHandler

Types

type CallOptions

type CallOptions func(userID string) []grpc.CallOption

CallOptions returns PerRPCCredentials for the requested user.

type Config

type Config struct {
	TestTypes map[string]bool

	WriteQPS   int
	WriteCount int

	BatchWriteQPS   int
	BatchWriteCount int
	BatchWriteSize  int

	ReadQPS      int
	ReadCount    int
	ReadPageSize int

	HistoryQPS      int
	HistoryCount    int
	HistoryPageSize int

	Duration time.Duration
}

Config tells the hammer what operations to do and how fast to go.

type DialFunc

type DialFunc func(ctx context.Context, addr string, opts ...grpc.DialOption) (pb.KeyTransparencyClient, error)

DialFunc returns a connected grpc client for Key Transparency.

type Hammer

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

Hammer represents a single run of the hammer.

func New

func New(ctx context.Context, dial DialFunc, callOptions CallOptions,
	ktAddr, directoryID string, timeout time.Duration, keyset *tink.KeysetHandle) (*Hammer, error)

New returns a new hammer job

func (*Hammer) Run

func (h *Hammer) Run(ctx context.Context, numWorkers int, c Config) error

Run runs a total of operationCount operations across numWorkers. The number of workers should roughly be (goal QPS) * (timeout seconds).

type ReqHandler

type ReqHandler func(ctx context.Context, arg *reqArgs) error

ReqHandler executes a request.