mocktest

package
v1.34.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ColonSeparator = ":"
)

Variables

View Source
var (
	LogOn   = os.Getenv("DOCKER_TESTING_LOG_OFF") == ""
	Print   = fmt.Print
	Printf  = fmt.Printf
	Println = fmt.Println
)

Functions

func Log added in v1.34.0

func Log(tb testing.TB, a ...interface{})

func PostToMaster

func PostToMaster(method, url string, reqData []byte) (resp *http.Response, err error)

func SetOutput added in v1.34.0

func SetOutput(w io.Writer)

SetOutput reset fmt output writer.

Types

type MockDataPartition

type MockDataPartition struct {
	PartitionID      uint64
	PersistenceHosts []string

	VolName           string
	Forbidden         int32
	DpRepairBlockSize uint64
	// contains filtered or unexported fields
}

func (*MockDataPartition) GetDpRepairBlockSize added in v1.34.0

func (md *MockDataPartition) GetDpRepairBlockSize() (size uint64)

func (*MockDataPartition) IsForbidden added in v1.34.0

func (md *MockDataPartition) IsForbidden() bool

func (*MockDataPartition) SetDpRepairBlockSize added in v1.34.0

func (md *MockDataPartition) SetDpRepairBlockSize(size uint64)

func (*MockDataPartition) SetForbidden added in v1.34.0

func (md *MockDataPartition) SetForbidden(status bool)

type MockDataServer

type MockDataServer struct {
	TcpAddr                         string
	Zone                            string
	ClusterID                       string
	Total                           uint64
	Used                            uint64
	Available                       uint64
	CreatedPartitionWeights         uint64 // dataPartitionCnt*dataPartitionSize
	RemainWeightsForCreatePartition uint64 // all-useddataPartitionsWieghts
	CreatedPartitionCnt             uint64
	MaxWeightsForCreatePartition    uint64

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMockDataServer

func NewMockDataServer(addr string, zoneName string) *MockDataServer

func (*MockDataServer) CheckVolPartition added in v1.34.0

func (mds *MockDataServer) CheckVolPartition(name string, cond func(*MockDataPartition) bool) bool

func (*MockDataServer) Start

func (mds *MockDataServer) Start()

type MockMetaPartition

type MockMetaPartition struct {
	PartitionID    uint64
	Start          uint64
	End            uint64
	Status         int8
	Cursor         uint64
	VolName        string
	Members        []proto.Peer
	Replicas       []*MockMetaReplica
	Forbidden      int32
	EnableAuditLog int32
}

func (*MockMetaPartition) IsEnableAuditLog added in v1.34.0

func (mm *MockMetaPartition) IsEnableAuditLog() bool

func (*MockMetaPartition) IsForbidden added in v1.34.0

func (mm *MockMetaPartition) IsForbidden() bool

func (*MockMetaPartition) SetEnableAuditLog added in v1.34.0

func (mm *MockMetaPartition) SetEnableAuditLog(status bool)

func (*MockMetaPartition) SetForbidden added in v1.34.0

func (mm *MockMetaPartition) SetForbidden(status bool)

type MockMetaReplica added in v1.34.0

type MockMetaReplica struct {
	Addr string

	MaxInodeID  uint64
	InodeCount  uint64
	DentryCount uint64
	ReportTime  int64
	Status      int8 // unavailable, readOnly, readWrite
	IsLeader    bool
	// contains filtered or unexported fields
}

MockMetaReplica defines the replica of a meta partition

type MockMetaServer

type MockMetaServer struct {
	NodeID   uint64
	TcpAddr  string
	ZoneName string

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMockMetaServer

func NewMockMetaServer(addr string, zoneName string) *MockMetaServer

func (*MockMetaServer) CheckVolPartition added in v1.34.0

func (mms *MockMetaServer) CheckVolPartition(name string, cond func(*MockMetaPartition) bool) bool

func (*MockMetaServer) Start

func (mms *MockMetaServer) Start()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL