service

package

v0.0.0-...-194279b Latest Latest Go to latest Published: Aug 5, 2020 License: MIT Imports: 35 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/whiteblock/genesis-cli

Documentation ¶

Index ¶

func Attach(cmd common.ExecAttach) error
func CheckForUpdates(version string) <-chan bool
func DefinitionDist(filename string) ([]*entity.ResourceDist, definition.Definition, error)
func DefinitionEnv(filename string) ([]map[string]string, definition.Definition, error)
func DefinitionFromFile(filename string) (def definition.Definition, err error)
func ExtractFiles(specData []byte) ([]string, error)
func GetCAdContainers(host string) ([]string, error)
func GetContainerName(host, containerPath string) (string, error)
func GetContainerStats(host, containerPath string) ([]v2.ContainerStats, error)
func GetMostRecentTest(org string) (common.Test, error)
func GetOrgID(orgID string) (string, error)
func GetStatus(testID string) (map[string]interface{}, error)
func GetStatusRaw(testID string) (common.Status, error)
func GetTests(orgNameOrId string, max int64, start int64) ([]common.Test, error)
func ListContainers(testID string) (out []string, err error)
func ListDefinitionsByOrg(orgID string) (out []common.TestDefinition, err error)
func ListTestsByDefinition(defID string) (out []common.Test, err error)
func LogStream(testID string) error
func PrepareExec(cmd common.Exec) (common.ExecInfo, error)
func ProcessDefinitionFromBytes(data []byte) (tests []command.Test, def definition.Definition, err error)
func ProcessDefinitionFromFile(filename string) (tests []command.Test, def definition.Definition, err error)
func RunDetach(cmd common.ExecAttach) error
func RunTest(meta definition.MetaPlus, orgNameOrId string, definitionID string) (out []string, err error)
func StopTest(id string, isDef bool, access biome.CloudAccess) error
func TestHosts(testID string) ([]string, error)
func TestInfo(testID string) (out common.TestInfo, err error)
func UploadFiles(filePath string, specData []byte, orgNameOrId string) ([]byte, string, error)
type CADAggregator
- func NewCADAggregator(host string, interval time.Duration) *CADAggregator
- func (ca *CADAggregator) Start() <-chan ContainerStatsOutput
type ContainerStatsOutput
type ContainerStreamer
- func NewContainerStreamer(host, containerPath string, interval time.Duration) *ContainerStreamer
- func (cs *ContainerStreamer) Close()
- func (cs *ContainerStreamer) Start(output chan ContainerStatsOutput) error
type DockerResp
type Error
type GatherCADAggregator
- func NewGatherCADAggregator(hosts []string, interval time.Duration) *GatherCADAggregator
- func (gca *GatherCADAggregator) Start() <-chan ContainerStatsOutput
type Named
type Response

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Attach ¶

func Attach(cmd common.ExecAttach) error

func CheckForUpdates ¶

func CheckForUpdates(version string) <-chan bool

func DefinitionDist ¶

func DefinitionDist(filename string) ([]*entity.ResourceDist, definition.Definition, error)

func DefinitionEnv ¶

func DefinitionEnv(filename string) ([]map[string]string, definition.Definition, error)

func DefinitionFromFile ¶

func DefinitionFromFile(filename string) (def definition.Definition, err error)

func ExtractFiles ¶

func ExtractFiles(specData []byte) ([]string, error)

func GetCAdContainers ¶

func GetCAdContainers(host string) ([]string, error)

func GetContainerName ¶

func GetContainerName(host, containerPath string) (string, error)

func GetContainerStats ¶

func GetContainerStats(host, containerPath string) ([]v2.ContainerStats, error)

func GetMostRecentTest ¶

func GetMostRecentTest(org string) (common.Test, error)

func GetOrgID ¶

func GetOrgID(orgID string) (string, error)

func GetStatus ¶

func GetStatus(testID string) (map[string]interface{}, error)

func GetStatusRaw ¶

func GetStatusRaw(testID string) (common.Status, error)

func GetTests ¶

func GetTests(orgNameOrId string, max int64, start int64) ([]common.Test, error)

func ListContainers ¶

func ListContainers(testID string) (out []string, err error)

func ListDefinitionsByOrg ¶

func ListDefinitionsByOrg(orgID string) (out []common.TestDefinition, err error)

func ListTestsByDefinition ¶

func ListTestsByDefinition(defID string) (out []common.Test, err error)

func LogStream ¶

func LogStream(testID string) error

func PrepareExec ¶

func PrepareExec(cmd common.Exec) (common.ExecInfo, error)

func ProcessDefinitionFromBytes ¶

func ProcessDefinitionFromBytes(data []byte) (tests []command.Test, def definition.Definition, err error)

func ProcessDefinitionFromFile ¶

func ProcessDefinitionFromFile(filename string) (tests []command.Test, def definition.Definition, err error)

func RunDetach ¶

func RunDetach(cmd common.ExecAttach) error

func RunTest ¶

func RunTest(meta definition.MetaPlus, orgNameOrId string,
	definitionID string) (out []string, err error)

func StopTest ¶

func StopTest(id string, isDef bool, access biome.CloudAccess) error

func TestHosts ¶

func TestHosts(testID string) ([]string, error)

func TestInfo ¶

func TestInfo(testID string) (out common.TestInfo, err error)

func UploadFiles ¶

func UploadFiles(filePath string, specData []byte, orgNameOrId string) ([]byte, string, error)

Types ¶

type CADAggregator ¶

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

func NewCADAggregator ¶

func NewCADAggregator(host string, interval time.Duration) *CADAggregator

func (*CADAggregator) Start ¶

func (ca *CADAggregator) Start() <-chan ContainerStatsOutput

type ContainerStatsOutput ¶

type ContainerStatsOutput struct {
	v2.ContainerStats
	Container string `json:"container"`
}

type ContainerStreamer ¶

type ContainerStreamer struct {
	Host          string
	ContainerPath string
	// contains filtered or unexported fields
}

func NewContainerStreamer ¶

func NewContainerStreamer(host, containerPath string, interval time.Duration) *ContainerStreamer

func (*ContainerStreamer) Close ¶

func (cs *ContainerStreamer) Close()

func (*ContainerStreamer) Start ¶

func (cs *ContainerStreamer) Start(output chan ContainerStatsOutput) error

type DockerResp ¶

type DockerResp struct {
	Named
	SubContainers []Named `json:"subcontainers"`
}

type Error ¶

type Error struct {
	Message string
	Info    []string
}

type GatherCADAggregator ¶

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

func NewGatherCADAggregator ¶

func NewGatherCADAggregator(hosts []string, interval time.Duration) *GatherCADAggregator

func (*GatherCADAggregator) Start ¶

func (gca *GatherCADAggregator) Start() <-chan ContainerStatsOutput

type Named ¶

type Named struct {
	Name string `json:"name"`
}

type Response ¶

type Response struct {
	Data interface{} `json:"data"`

	Error *Error   `json:"error,omitempty"`
	Meta  struct{} `json:"meta"`
}

Source Files ¶

View all Source files

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