clients

Documentation

Index

• type BuildkiteAPI
  • func CreateBuildkiteAPI(apiToken string, debug bool) (BuildkiteAPI, error)
• type BuildkiteAPIWrapper
  • func (bk *BuildkiteAPIWrapper) ListAgents(org string, page, perPage int) ([]buildkite.Agent, int, error)
  • func (bk *BuildkiteAPIWrapper) ListBuildsByPipeline(org, pipeline string, page, perPage int) ([]buildkite.Build, int, error)
  • func (bk *BuildkiteAPIWrapper) ListBuildyByOrg(org string, page, perPage int) ([]buildkite.Build, int, error)
• type BuildkiteClient
• type CachedBuildkiteClient
  • func CreateCachedBuildkiteClient(api BuildkiteAPI, cacheTimeout time.Duration) *CachedBuildkiteClient
  • func (client *CachedBuildkiteClient) GetAgents(org string) ([]buildkite.Agent, error)
  • func (client *CachedBuildkiteClient) GetMostRecentBuilds(pipeline *data.PipelineID, atLeastNBuilds int) ([]buildkite.Build, error)
• type Clock
• type CloudStorageClient
  • func CreateCloudStorageClient() (*CloudStorageClient, error)
  • func (c *CloudStorageClient) ReadAllFiles(bucket, directory string) (*cloudStorageFileIter, error)
• type ComputeEngineClient
  • func CreateComputeEngineClient() (*ComputeEngineClient, error)
  • func (c *ComputeEngineClient) GetAllInstances(projects []string) ([]*ComputeInstance, error)
• type ComputeInstance
• type DefaultClock
  • func (DefaultClock) CurrentTime() time.Time
• type StackdriverClient
  • func CreateStackdriverClient() (*StackdriverClient, error)
  • func (sc *StackdriverClient) WriteTimeSeries(request *monitoringpb.CreateTimeSeriesRequest) error

Types

type BuildkiteAPI

type BuildkiteAPI interface {
	ListAgents(org string, page, perPage int) ([]buildkite.Agent, int, error)
	ListBuildyByOrg(org string, page, perPage int) ([]buildkite.Build, int, error)
	ListBuildsByPipeline(org, pipeline string, page, perPage int) ([]buildkite.Build, int, error)
}

func CreateBuildkiteAPI

func CreateBuildkiteAPI(apiToken string, debug bool) (BuildkiteAPI, error)

type BuildkiteAPIWrapper

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

func (*BuildkiteAPIWrapper) ListAgents

func (bk *BuildkiteAPIWrapper) ListAgents(org string, page, perPage int) ([]buildkite.Agent, int, error)

func (*BuildkiteAPIWrapper) ListBuildsByPipeline

func (bk *BuildkiteAPIWrapper) ListBuildsByPipeline(org, pipeline string, page, perPage int) ([]buildkite.Build, int, error)

func (*BuildkiteAPIWrapper) ListBuildyByOrg

func (bk *BuildkiteAPIWrapper) ListBuildyByOrg(org string, page, perPage int) ([]buildkite.Build, int, error)

type BuildkiteClient

type BuildkiteClient interface {
	GetMostRecentBuilds(*data.PipelineID, int) ([]buildkite.Build, error)
	GetAgents(string) ([]buildkite.Agent, error)
}

type CachedBuildkiteClient

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

func CreateCachedBuildkiteClient

func CreateCachedBuildkiteClient(api BuildkiteAPI, cacheTimeout time.Duration) *CachedBuildkiteClient

func (*CachedBuildkiteClient) GetAgents

func (client *CachedBuildkiteClient) GetAgents(org string) ([]buildkite.Agent, error)

func (*CachedBuildkiteClient) GetMostRecentBuilds

func (client *CachedBuildkiteClient) GetMostRecentBuilds(pipeline *data.PipelineID, atLeastNBuilds int) ([]buildkite.Build, error)

type Clock

type Clock interface {
	CurrentTime() time.Time
}

type CloudStorageClient

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

func CreateCloudStorageClient

func CreateCloudStorageClient() (*CloudStorageClient, error)

func (*CloudStorageClient) ReadAllFiles

func (c *CloudStorageClient) ReadAllFiles(bucket, directory string) (*cloudStorageFileIter, error)

type ComputeEngineClient

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

func CreateComputeEngineClient

func CreateComputeEngineClient() (*ComputeEngineClient, error)

func (*ComputeEngineClient) GetAllInstances

func (c *ComputeEngineClient) GetAllInstances(projects []string) ([]*ComputeInstance, error)

type ComputeInstance

type ComputeInstance struct {
	Name         string
	Zone         string
	Project      string
	Status       string
	CreationTime time.Time
}

type DefaultClock

type DefaultClock struct{}

func (DefaultClock) CurrentTime

func (DefaultClock) CurrentTime() time.Time

type StackdriverClient

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

func CreateStackdriverClient

func CreateStackdriverClient() (*StackdriverClient, error)

func (*StackdriverClient) WriteTimeSeries

func (sc *StackdriverClient) WriteTimeSeries(request *monitoringpb.CreateTimeSeriesRequest) error