Documentation ¶
Index ¶
- func AppendLogToChanges(logPath, changesPath, arch string) error
- func Download(url string) (func(), string, error)
- func FakeChanges(date, source, binary, arch, version, distribution, urgency string, ...) (string, error)
- func Filename(source string, v version.Version, arch, flavor string) string
- func GetBuildChannels(channels *BuildChannelMap, suites []BuildableSuite) []chan Build
- func HashFile(path string, algo hash.Hash) (string, error)
- func LogChangesFromChanges(logPath, changesPath, arch string) (string, error)
- func LogChangesFromDsc(logPath string, dsc control.DSC, suite, arch string) (string, error)
- func MergeChanges(changes ...string) (string, error)
- func ParseDscURL(url string) (*control.DSC, error)
- func Tempdir() (func(), string, error)
- func UploadChanges(conf MinionConfig, job Build, changesPath string) error
- type Archive
- type BinNMU
- type Build
- type BuildChannelMap
- type BuildNeedingRequest
- type BuildableSuite
- type Chroot
- type CoordinatorProxy
- func (p *CoordinatorProxy) GetBuildNeeding(repo, suite, arch, pkg string) ([]reprepro.BuildNeedingPackage, error)
- func (p *CoordinatorProxy) GetOnlineMinions() ([]string, error)
- func (p *CoordinatorProxy) GetQueueLengths() (map[string]int, error)
- func (p *CoordinatorProxy) Heartbeat() ([]string, error)
- func (p *CoordinatorProxy) QueueBuild(build Build) error
- type CoordinatorRemote
- func (c *CoordinatorRemote) GetBuildNeeding(buildNeedingRequest BuildNeedingRequest, ret *[]reprepro.BuildNeedingPackage) error
- func (c *CoordinatorRemote) GetOnlineMinions(incoming bool, ret *[]string) error
- func (c *CoordinatorRemote) GetQueueLengths(incoming bool, ret *map[string]int) error
- func (c *CoordinatorRemote) Heartbeat(incoming bool, ret *[]string) error
- func (c *CoordinatorRemote) QueueBuild(build Build, r *interface{}) error
- type MinionConfig
- type MinionProxy
- type MinionRemote
- type OnlineClient
- type OnlineClients
- type Upload
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppendLogToChanges ¶
func FakeChanges ¶
func GetBuildChannels ¶
func GetBuildChannels( channels *BuildChannelMap, suites []BuildableSuite, ) []chan Build
func LogChangesFromChanges ¶
func LogChangesFromDsc ¶
Take a DSC, and a log file, and create a fake .changes to upload the log to the archive. This relies on a reprepro extension.
func MergeChanges ¶
func UploadChanges ¶
func UploadChanges(conf MinionConfig, job Build, changesPath string) error
Types ¶
type Build ¶
type Build struct { Archives []Archive Chroot Chroot DSC string Arch string Upload Upload BinNMU BinNMU }
func (Build) GetBuildChannelKey ¶
type BuildChannelMap ¶
func (BuildChannelMap) Get ¶
func (b BuildChannelMap) Get(arch string) chan Build
type BuildNeedingRequest ¶
type BuildableSuite ¶
func (*BuildableSuite) GetKey ¶
func (b *BuildableSuite) GetKey() string
type CoordinatorProxy ¶
func (*CoordinatorProxy) GetBuildNeeding ¶
func (p *CoordinatorProxy) GetBuildNeeding(repo, suite, arch, pkg string) ([]reprepro.BuildNeedingPackage, error)
func (*CoordinatorProxy) GetOnlineMinions ¶
func (p *CoordinatorProxy) GetOnlineMinions() ([]string, error)
func (*CoordinatorProxy) GetQueueLengths ¶
func (p *CoordinatorProxy) GetQueueLengths() (map[string]int, error)
func (*CoordinatorProxy) Heartbeat ¶
func (p *CoordinatorProxy) Heartbeat() ([]string, error)
func (*CoordinatorProxy) QueueBuild ¶
func (p *CoordinatorProxy) QueueBuild(build Build) error
type CoordinatorRemote ¶
type CoordinatorRemote struct { Config *MinionConfig Clients *OnlineClients // contains filtered or unexported fields }
func NewCoordinatorRemote ¶
func NewCoordinatorRemote( buildChannels *BuildChannelMap, config *MinionConfig, clients *OnlineClients, ) CoordinatorRemote
func (*CoordinatorRemote) GetBuildNeeding ¶
func (c *CoordinatorRemote) GetBuildNeeding( buildNeedingRequest BuildNeedingRequest, ret *[]reprepro.BuildNeedingPackage, ) error
func (*CoordinatorRemote) GetOnlineMinions ¶
func (c *CoordinatorRemote) GetOnlineMinions(incoming bool, ret *[]string) error
func (*CoordinatorRemote) GetQueueLengths ¶
func (c *CoordinatorRemote) GetQueueLengths(incoming bool, ret *map[string]int) error
func (*CoordinatorRemote) Heartbeat ¶
func (c *CoordinatorRemote) Heartbeat(incoming bool, ret *[]string) error
func (*CoordinatorRemote) QueueBuild ¶
func (c *CoordinatorRemote) QueueBuild(build Build, r *interface{}) error
type MinionConfig ¶
type MinionConfig struct { Cert string `flag:"cert" description:"OpenSSL Client or Server .crt to serve to the world."` Key string `flag:"key" description:"OpenSSL Client or Server .key to do private key things with."` CaCert string `flag:"ca-cert" description:"OpenSSL CA Cert to compare the server or client certs to."` Host string `flag:"host" description:"Name of the Host that we're either serving on behalf of, or connecting to."` Port int `flag:"port" description:"Port we're connecting to on the host."` Mode string `flag:"mode" description:"Mode to run as."` Administrator string `flag:"administrator" description:""` Templates string `flag:"templates" description:"templates"` Repos string `flag:"repos" description:"repos"` }
type MinionProxy ¶
func (*MinionProxy) GetBuildableSuites ¶
func (m *MinionProxy) GetBuildableSuites() ([]BuildableSuite, error)
func (*MinionProxy) Heartbeat ¶
func (m *MinionProxy) Heartbeat() error
type MinionRemote ¶
type MinionRemote struct { BuildableSuites []BuildableSuite Config MinionConfig }
func NewMinionRemote ¶
func NewMinionRemote(config MinionConfig, suites []BuildableSuite) MinionRemote
func (*MinionRemote) GetBuildableSuites ¶
func (m *MinionRemote) GetBuildableSuites(i *bool, ret *[]BuildableSuite) error
type OnlineClient ¶
type OnlineClient struct { Name string Proxy *MinionProxy }
type OnlineClients ¶
type OnlineClients map[*OnlineClient]bool
func (OnlineClients) Add ¶
func (o OnlineClients) Add(client *OnlineClient)
func (OnlineClients) Remove ¶
func (o OnlineClients) Remove(client *OnlineClient)
Click to show internal directories.
Click to hide internal directories.