admin

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

type AdminClientProvider interface {
	GetAdminClient(hdb *hapi.HStreamDB) IAdminClient
}

type HMetaNode struct {
	Reachable bool
	Leader    bool
	Error     string
}

type HMetaStatus struct {
	Nodes map[string]HMetaNode
}

type IAdminClient interface {
	CallServer(args ...string) (string, error)
	CallStore(args ...string) (string, error)
	MaintenanceStore(action MaintenanceAction, args ...string) (string, error)
	GetHMetaStatus() (HMetaStatus, error)
}

type MaintenanceAction string