service

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

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"`
}