consumer

Documentation

Index

• func NewEventContextFromPullRequest(event *github.PullRequestEvent) *eventContext
• func NewEventContextFromPushEvent(event *github.PushEvent) *eventContext
• func NewKubernetesClient() (*kubernetes.Clientset, error)
• func WaitForFinish(client *kubernetes.Clientset, namespace, name string) (bool, error)
• type BazelBuild
  • func NewBuildConsumer(namespace string, conf *config.Config, debug bool) (*BazelBuild, error)
  • func (b *BazelBuild) Build(e interface{})
• type DNSControlConsumer
  • func NewDNSControlConsumer(namespace string, conf *config.Config, safeMode, debug bool) (*DNSControlConsumer, error)
  • func (c *DNSControlConsumer) Dispatch(e interface{})

Functions

func NewEventContextFromPullRequest

func NewEventContextFromPullRequest(event *github.PullRequestEvent) *eventContext

func NewEventContextFromPushEvent

func NewEventContextFromPushEvent(event *github.PushEvent) *eventContext

func NewKubernetesClient

func NewKubernetesClient() (*kubernetes.Clientset, error)

func WaitForFinish

func WaitForFinish(client *kubernetes.Clientset, namespace, name string) (bool, error)

Types

type BazelBuild

type BazelBuild struct {
	Namespace              string
	AppId                  int64
	InstallationId         int64
	StorageHost            string
	StorageTokenSecretName string
	ArtifactBucket         string
	HostAliases            []config.HostAlias
	AuthorName             string
	AuthorEmail            string
	// contains filtered or unexported fields
}

func NewBuildConsumer

func NewBuildConsumer(namespace string, conf *config.Config, debug bool) (*BazelBuild, error)

func (*BazelBuild) Build

func (b *BazelBuild) Build(e interface{})

type DNSControlConsumer

type DNSControlConsumer struct {
	Namespace            string
	HostAliases          []config.HostAlias
	AppId                int64
	InstallationId       int64
	PrivateKeySecretName string
	// contains filtered or unexported fields
}

func NewDNSControlConsumer

func NewDNSControlConsumer(namespace string, conf *config.Config, safeMode, debug bool) (*DNSControlConsumer, error)

func (*DNSControlConsumer) Dispatch

func (c *DNSControlConsumer) Dispatch(e interface{})