test

Documentation

Index

• type CaptureResponse
  • func MakeCaptureResponse() *CaptureResponse
  • func (w *CaptureResponse) Header() http.Header
  • func (w *CaptureResponse) Write(b []byte) (int, error)
  • func (w *CaptureResponse) WriteHeader(status int)
• type FakeMemcacheRing
  • func (mr *FakeMemcacheRing) Decr(ctx context.Context, key string, delta int64, timeout int) (int64, error)
  • func (mr *FakeMemcacheRing) Delete(ctx context.Context, key string) error
  • func (mr *FakeMemcacheRing) Get(ctx context.Context, key string) (interface{}, error)
  • func (mr *FakeMemcacheRing) GetMulti(ctx context.Context, serverKey string, keys []string) (map[string]interface{}, error)
  • func (mr *FakeMemcacheRing) GetStructured(ctx context.Context, key string, val interface{}) error
  • func (mr *FakeMemcacheRing) Incr(ctx context.Context, key string, delta int64, timeout int) (int64, error)
  • func (mr *FakeMemcacheRing) Set(ctx context.Context, key string, value interface{}, timeout int) error
  • func (mr *FakeMemcacheRing) SetMulti(ctx context.Context, serverKey string, values map[string]interface{}, ...) error
• type FakeRing
  • func (r *FakeRing) AllDevices() (devs []*ring.Device)
  • func (r *FakeRing) GetJobNodes(partition uint64, localDevice int) (response []*ring.Device, handoff bool)
  • func (r *FakeRing) GetMoreNodes(partition uint64) ring.MoreNodes
  • func (r *FakeRing) GetNodes(partition uint64) (response []*ring.Device)
  • func (r *FakeRing) GetPartition(account string, container string, object string) uint64
  • func (r *FakeRing) LocalDevices(localPort int) (devs []*ring.Device, err error)
  • func (r *FakeRing) PartitionCount() uint64
  • func (r *FakeRing) PartitionForHash(hsh string) (uint64, error)
  • func (r *FakeRing) ReplicaCount() uint64
• type MockResponseWriter
  • func (m MockResponseWriter) Header() (h http.Header)
  • func (m MockResponseWriter) Write(p []byte) (n int, err error)
  • func (m MockResponseWriter) WriteHeader(s int)
  • func (m MockResponseWriter) WriteString(s string) (n int, err error)

Types

type CaptureResponse

type CaptureResponse struct {
	Status int

	Body *bytes.Buffer
	// contains filtered or unexported fields
}

func MakeCaptureResponse

func MakeCaptureResponse() *CaptureResponse

func (*CaptureResponse) Header

func (w *CaptureResponse) Header() http.Header

func (*CaptureResponse) Write

func (w *CaptureResponse) Write(b []byte) (int, error)

func (*CaptureResponse) WriteHeader

func (w *CaptureResponse) WriteHeader(status int)

type FakeMemcacheRing

type FakeMemcacheRing struct {
	MockIncrResults   []int64
	MockIncrKeys      []string
	MockSetValues     []interface{}
	MockGetStructured map[string][]byte
}

Fake MemcacheRing

func (*FakeMemcacheRing) Decr

func (mr *FakeMemcacheRing) Decr(ctx context.Context, key string, delta int64, timeout int) (int64, error)

func (*FakeMemcacheRing) Delete

func (mr *FakeMemcacheRing) Delete(ctx context.Context, key string) error

func (*FakeMemcacheRing) Get

func (mr *FakeMemcacheRing) Get(ctx context.Context, key string) (interface{}, error)

func (*FakeMemcacheRing) GetMulti

func (mr *FakeMemcacheRing) GetMulti(ctx context.Context, serverKey string, keys []string) (map[string]interface{}, error)

func (*FakeMemcacheRing) GetStructured

func (mr *FakeMemcacheRing) GetStructured(ctx context.Context, key string, val interface{}) error

func (*FakeMemcacheRing) Incr

func (mr *FakeMemcacheRing) Incr(ctx context.Context, key string, delta int64, timeout int) (int64, error)

func (*FakeMemcacheRing) Set

func (mr *FakeMemcacheRing) Set(ctx context.Context, key string, value interface{}, timeout int) error

func (*FakeMemcacheRing) SetMulti

func (mr *FakeMemcacheRing) SetMulti(ctx context.Context, serverKey string, values map[string]interface{}, timeout int) error

type FakeRing

type FakeRing struct {
	// Overrides for function returns
	MockLocalDevices       []*ring.Device
	MockGetJobNodes        []*ring.Device
	MockGetJobNodesHandoff bool
	MockGetMoreNodes       ring.MoreNodes

	// Used for probe
	MockMoreNodes *ring.Device
	MockDevices   []*ring.Device
}

FakeRing

func (*FakeRing) AllDevices

func (r *FakeRing) AllDevices() (devs []*ring.Device)

func (*FakeRing) GetJobNodes

func (r *FakeRing) GetJobNodes(partition uint64, localDevice int) (response []*ring.Device, handoff bool)

func (*FakeRing) GetMoreNodes

func (r *FakeRing) GetMoreNodes(partition uint64) ring.MoreNodes

func (*FakeRing) GetNodes

func (r *FakeRing) GetNodes(partition uint64) (response []*ring.Device)

func (*FakeRing) GetPartition

func (r *FakeRing) GetPartition(account string, container string, object string) uint64

func (*FakeRing) LocalDevices

func (r *FakeRing) LocalDevices(localPort int) (devs []*ring.Device, err error)

func (*FakeRing) PartitionCount

func (r *FakeRing) PartitionCount() uint64

func (*FakeRing) PartitionForHash

func (r *FakeRing) PartitionForHash(hsh string) (uint64, error)

func (*FakeRing) ReplicaCount

func (r *FakeRing) ReplicaCount() uint64

type MockResponseWriter

type MockResponseWriter struct {
	SaveHeader *http.Header
	StatusMap  map[string]int
	Body       io.Writer
}

func (MockResponseWriter) Header

func (m MockResponseWriter) Header() (h http.Header)

func (MockResponseWriter) Write

func (m MockResponseWriter) Write(p []byte) (n int, err error)

func (MockResponseWriter) WriteHeader

func (m MockResponseWriter) WriteHeader(s int)

func (MockResponseWriter) WriteString

func (m MockResponseWriter) WriteString(s string) (n int, err error)