pubsub

Documentation

Index

• Constants
• func WithKeepAliveDialer() grpc.DialOption
• type DefaultManager
  • func NewDefaultManager(clusterName, projectID string, providers provider.Providers, ...) *DefaultManager
  • func (s *DefaultManager) Start(ctx context.Context) error
• type Message
• type Opts
• type PubsubSubscriber
  • func NewPubsubSubscriber(opts *Opts) (*PubsubSubscriber, error)
  • func (s *PubsubSubscriber) Subscribe(ctx context.Context, topic, subscription string) error
• type Subscriber

Constants

const MetadataEndpoint = "http://metadata/computeMetadata/v1/instance/attributes/cluster-name"

MetadataEndpoint - default metadata server for gcloud pubsub

Functions

func WithKeepAliveDialer

func WithKeepAliveDialer() grpc.DialOption

WithKeepAliveDialer - required so connections aren't dropped https://github.com/GoogleCloudPlatform/google-cloud-go/issues/500

Types

type DefaultManager

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

DefaultManager - subscription manager

func NewDefaultManager

func NewDefaultManager(clusterName, projectID string, providers provider.Providers, subClient Subscriber) *DefaultManager

NewDefaultManager - creates new pubsub manager to create subscription for deployments

func (*DefaultManager) Start

func (s *DefaultManager) Start(ctx context.Context) error

Start - start scanning deployment for changes

type Message

type Message struct {
	Action string `json:"action,omitempty"`
	Digest string `json:"digest"`
	Tag    string `json:"tag,omitempty"`
}

Message - expected message from gcr

type Opts

type Opts struct {
	ProjectID string
	Providers provider.Providers
}

Opts - subscriber options

type PubsubSubscriber

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

PubsubSubscriber is Google Cloud pubsub based subscriber

func NewPubsubSubscriber

func NewPubsubSubscriber(opts *Opts) (*PubsubSubscriber, error)

NewPubsubSubscriber - create new pubsub subscriber

func (*PubsubSubscriber) Subscribe

func (s *PubsubSubscriber) Subscribe(ctx context.Context, topic, subscription string) error

Subscribe - initiate PubsubSubscriber

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, topic, subscription string) error
}

Subscriber - subscribe is responsible to listen for repository events and inform providers