bkdata

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Jul 29, 2020 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultAPIVersion = "v1"

Variables

This section is empty.

Functions

This section is empty.

Types

type APIVersion

type APIVersion int
const (
	V1 APIVersion = iota
)

func (APIVersion) String

func (v APIVersion) String() string

type BookieSocketAddress

type BookieSocketAddress struct {
	Port     int    `json:"port"`
	HostName string `json:"hostname"`
}

type BookieType added in v0.3.0

type BookieType string

func ParseBookieType added in v0.3.0

func ParseBookieType(t string) (BookieType, error)

func (BookieType) String added in v0.3.0

func (t BookieType) String() string

type DecommissionRequest added in v0.3.0

type DecommissionRequest struct {
	BookieSrc string `json:"bookie_src"`
}

type FileType added in v0.3.0

type FileType string

func ParseFileType added in v0.3.0

func ParseFileType(fileType string) (FileType, error)

func (FileType) String added in v0.3.0

func (t FileType) String() string

type GCStatus added in v0.3.0

type GCStatus struct {
	// whether the GC thread is in force GC
	ForceCompacting bool `json:"forceCompacting"`
	// whether the GC thread is in major compacting
	MajorCompacting bool `json:"majorCompacting"`
	//whether the GC thread is in minor compacting
	MinorCompacting bool `json:"minorCompacting"`

	LastMajorCompactionTime int64 `json:"lastMajorCompactionTime"`
	LastMinorCompactionTime int64 `json:"lastMinorCompactionTime"`
	MajorCompactionCounter  int64 `json:"majorCompactionCounter"`
	MinorCompactionCounter  int64 `json:"minorCompactionCounter"`
}

type LedgerMetadata

type LedgerMetadata struct {
	StoreCtime            bool                            `json:"storeCtime"`
	HasPassword           bool                            `json:"hasPassword"`
	MetadataFormatVersion int                             `json:"metadataFormatVersion"`
	Ensemble              int                             `json:"ensembleSize"`
	WriteQuorum           int                             `json:"writeQuorumSize"`
	AckQuorum             int                             `json:"ackQuorumSize"`
	Length                int64                           `json:"length"`
	LastEntryID           int64                           `json:"lastEntryId"`
	Ctime                 int64                           `json:"ctime"`
	CToken                int64                           `json:"cToken"`
	State                 string                          `json:"state"`
	DigestType            string                          `json:"digestType"`
	Ensembles             map[int64][]BookieSocketAddress `json:"allEnsembles"`
	CurrentEnsemble       []BookieSocketAddress           `json:"currentEnsemble"`
	Password              []byte                          `json:"password"`
	CustomMetadata        map[string][]byte               `json:"customMetadata"`
}

type LostBookieRecoverDelayRequest added in v0.3.0

type LostBookieRecoverDelayRequest struct {
	DelaySeconds int `json:"delay_seconds"`
}

type RecoveryRequest added in v0.3.0

type RecoveryRequest struct {
	BookieSrc    []string `json:"bookie_src"`
	DeleteCookie bool     `json:"delete_cookie"`
}

type State added in v0.3.0

type State struct {
	Running                        bool `json:"running"`
	ReadOnly                       bool `json:"readOnly"`
	ShuttingDown                   bool `json:"shuttingDown"`
	AvailableForHighPriorityWrites bool `json:"availableForHighPriorityWrites"`
}

Jump to

Keyboard shortcuts

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