test

Documentation

Index

• func GenerateKey(path string) (string, error)
• func GetDefaultConfigMap() map[string]interface{}
• func Handler(resp *Response) func(http.ResponseWriter, *http.Request)
• func InitDatabaseFromEnv()
• func NewAdminserver(config map[string]interface{}) (*httptest.Server, error)
• func NewCapacityHandle() (func(http.ResponseWriter, *http.Request), error)
• func NewRegistryCtl(config map[string]interface{}) (*httptest.Server, error)
• func NewServer(mappings ...*RequestHandlerMapping) *httptest.Server
• type FakePolicyManager
  • func (f *FakePolicyManager) CreatePolicy(policy models.ReplicationPolicy) (int64, error)
  • func (f *FakePolicyManager) GetPolicies(query models.QueryParameter) (*models.ReplicationPolicyQueryResult, error)
  • func (f *FakePolicyManager) GetPolicy(id int64) (models.ReplicationPolicy, error)
  • func (f *FakePolicyManager) RemovePolicy(int64) error
  • func (f *FakePolicyManager) UpdatePolicy(models.ReplicationPolicy) error
• type FakeReplicatoinController
  • func (f *FakeReplicatoinController) Init() error
  • func (f *FakeReplicatoinController) Replicate(policyID int64, metadata ...map[string]interface{}) error
• type FakeWatchItemDAO
  • func (f *FakeWatchItemDAO) Add(item *models.WatchItem) (int64, error)
  • func (f *FakeWatchItemDAO) DeleteByPolicyID(policyID int64) error
  • func (f *FakeWatchItemDAO) Get(namespace, operation string) ([]models.WatchItem, error)
• type GCResult
• type RequestHandlerMapping
  • func (rhm *RequestHandlerMapping) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Response

Functions

func GenerateKey

func GenerateKey(path string) (string, error)

GenerateKey generates aes key

func GetDefaultConfigMap

func GetDefaultConfigMap() map[string]interface{}

GetDefaultConfigMap returns the defailt config map for easier modification.

func Handler

func Handler(resp *Response) func(http.ResponseWriter, *http.Request)

Handler returns a handler function which handle requst according to the response provided

func InitDatabaseFromEnv

func InitDatabaseFromEnv()

InitDatabaseFromEnv is used to initialize database for testing

func NewAdminserver

func NewAdminserver(config map[string]interface{}) (*httptest.Server, error)

NewAdminserver returns a mock admin server

func NewCapacityHandle

func NewCapacityHandle() (func(http.ResponseWriter, *http.Request), error)

NewCapacityHandle ...

func NewRegistryCtl

func NewRegistryCtl(config map[string]interface{}) (*httptest.Server, error)

NewRegistryCtl returns a mock registry server

func NewServer

func NewServer(mappings ...*RequestHandlerMapping) *httptest.Server

NewServer creates a HTTP server for unit test

Types

type FakePolicyManager

type FakePolicyManager struct {
}

func (*FakePolicyManager) CreatePolicy

func (f *FakePolicyManager) CreatePolicy(policy models.ReplicationPolicy) (int64, error)

func (*FakePolicyManager) GetPolicies

func (f *FakePolicyManager) GetPolicies(query models.QueryParameter) (*models.ReplicationPolicyQueryResult, error)

func (*FakePolicyManager) GetPolicy

func (f *FakePolicyManager) GetPolicy(id int64) (models.ReplicationPolicy, error)

func (*FakePolicyManager) RemovePolicy

func (f *FakePolicyManager) RemovePolicy(int64) error

func (*FakePolicyManager) UpdatePolicy

func (f *FakePolicyManager) UpdatePolicy(models.ReplicationPolicy) error

type FakeReplicatoinController

type FakeReplicatoinController struct {
	FakePolicyManager
}

func (*FakeReplicatoinController) Init

func (f *FakeReplicatoinController) Init() error

func (*FakeReplicatoinController) Replicate

func (f *FakeReplicatoinController) Replicate(policyID int64, metadata ...map[string]interface{}) error

type FakeWatchItemDAO

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

FakeWatchItemDAO is the fake implement for the dao.WatchItemDAO

func (*FakeWatchItemDAO) Add

func (f *FakeWatchItemDAO) Add(item *models.WatchItem) (int64, error)

Add ...

func (*FakeWatchItemDAO) DeleteByPolicyID

func (f *FakeWatchItemDAO) DeleteByPolicyID(policyID int64) error

DeleteByPolicyID : delete the WatchItem specified by policy ID

func (*FakeWatchItemDAO) Get

func (f *FakeWatchItemDAO) Get(namespace, operation string) ([]models.WatchItem, error)

Get returns WatchItem list according to the namespace and operation

type GCResult

type GCResult struct {
	Status    bool      `json:"status"`
	Msg       string    `json:"msg"`
	StartTime time.Time `json:"starttime"`
	EndTime   time.Time `json:"endtime"`
}

GCResult ...

type RequestHandlerMapping

type RequestHandlerMapping struct {
	// Method is the method the request used
	Method string
	// Pattern is the pattern the request must match
	Pattern string
	// Handler is the handler which handles the request
	Handler func(http.ResponseWriter, *http.Request)
}

RequestHandlerMapping is a mapping between request and its handler

func (*RequestHandlerMapping) ServeHTTP

func (rhm *RequestHandlerMapping) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP ...

type Response

type Response struct {
	// StatusCode is the status code of the response
	StatusCode int
	// Headers are the headers of the response
	Headers map[string]string
	// Boby is the body of the response
	Body []byte
}

Response is a response used for unit test