processor

Documentation

Index

• func DockerArgs(processor *resources.Processor) ([]string, error)
• func DockerCommand(processor *resources.Processor, message *RepositoryMessage) error
• type Discovery
• type DiscoveryStatus
• type Processor
• type Protocol
• type RepositoryMessage
  • func NewRepositoryMessage(repository *resources.Repository, intersection *build.DiscoveryIntersection) *RepositoryMessage
  • func (message *RepositoryMessage) WithProcessor(processor *resources.Processor)
  • func (message *RepositoryMessage) WithRebuilt(rebuilt []build.PairedDiscovery)
• type Source

Functions

func DockerArgs

func DockerArgs(processor *resources.Processor) ([]string, error)

func DockerCommand

func DockerCommand(processor *resources.Processor, message *RepositoryMessage) error

Types

type Discovery

type Discovery struct {
	Source         int               `json:"source"`
	DiscoPath      string            `json:"discoPath"`
	DiscoHash      string            `json:"discoHash"`
	DiscoHashType  string            `json:"discoHashType"`
	BuildPath      string            `json:"buildPath"`
	BuildTimestamp string            `json:"buildTimestamp"`
	BuildHash      string            `json:"buildHash"`
	BuildHashType  string            `json:"buildHashType"`
	Name           string            `json:"name"`
	Namespace      string            `json:"namespace"`
	Labels         map[string]string `json:"labels"`
	Annotations    map[string]string `json:"annotations"`
}

type DiscoveryStatus

type DiscoveryStatus struct {
	Delete  []Discovery `json:"delete"`
	Check   []Discovery `json:"check"`
	Rebuilt []Discovery `json:"rebuilt"`
	Create  []Discovery `json:"create"`
}

type Processor

type Processor struct {
	Name       string      `json:"name"`
	Stage      string      `json:"stage"`
	Properties interface{} `json:"properties"`
}

type Protocol

type Protocol string

Protocol is a semantic version string

const Protocol_0_1_0 Protocol = "0.1.0"

type RepositoryMessage

type RepositoryMessage struct {
	Protocol    Protocol        `json:"protocol"`
	Name        string          `json:"name"`
	RepoRoot    string          `json:"repoRoot"`
	BuildPath   string          `json:"buildPath"`
	Processor   Processor       `json:"processor"`
	Sources     []Source        `json:"sources"`
	Discoveries DiscoveryStatus `json:"discoveries"`
}

func NewRepositoryMessage

func NewRepositoryMessage(
	repository *resources.Repository,
	intersection *build.DiscoveryIntersection,
) *RepositoryMessage

func (*RepositoryMessage) WithProcessor

func (message *RepositoryMessage) WithProcessor(processor *resources.Processor)

func (*RepositoryMessage) WithRebuilt

func (message *RepositoryMessage) WithRebuilt(rebuilt []build.PairedDiscovery)

type Source

type Source struct {
	ID   int    `json:"id"`
	Name string `json:"name"`
}