pubsub

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MessageFormat_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "CUSTOM",
		2: "GCB",
		3: "GCS",
		4: "GCR",
	}
	MessageFormat_value = map[string]int32{
		"UNSPECIFIED": 0,
		"CUSTOM":      1,
		"GCB":         2,
		"GCS":         3,
		"GCR":         4,
	}
)

Enum value maps for MessageFormat.

View Source 
var File_pubsub_google_proto protoreflect.FileDescriptor
View Source 
var File_pubsub_pubsub_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Google 

type Google struct {

	// Whether Google Cloud Pub/Sub is enabled.
	Enabled *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// The list of configured subscriptions.
	Subscriptions []*GoogleSubscriber `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// The list of configured publishers.
	Publishers []*GooglePublisher `protobuf:"bytes,3,rep,name=publishers,proto3" json:"publishers,omitempty"`
	// contains filtered or unexported fields
}

Configuration for Google Cloud Pub/Sub integration.

func (*Google) Descriptor deprecated 

func (*Google) Descriptor() ([]byte, []int)

Deprecated: Use Google.ProtoReflect.Descriptor instead.

func (*Google) GetEnabled 

func (x *Google) GetEnabled() *wrapperspb.BoolValue

func (*Google) GetPublishers 

func (x *Google) GetPublishers() []*GooglePublisher

func (*Google) GetSubscriptions 

func (x *Google) GetSubscriptions() []*GoogleSubscriber

func (*Google) ProtoMessage 

func (*Google) ProtoMessage()

func (*Google) ProtoReflect 

func (x *Google) ProtoReflect() protoreflect.Message

func (*Google) Reset 

func (x *Google) Reset()

func (*Google) String 

func (x *Google) String() string

type GooglePublisher 

type GooglePublisher struct {

	// The name of the publisher account.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The name of the GCP project your topic lives in.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// The name of the topic to publish to. This identifier does not include the
	// name of the project, and must already be configured.
	TopicName string `protobuf:"bytes,3,opt,name=topicName,proto3" json:"topicName,omitempty"`
	// The path to a JSON service account that Spinnaker will use as credentials.
	// This is only needed if Spinnaker is not deployed on a Google Compute Engine
	// VM, or needs permissions not afforded to the VM it is running on.
	// See https://cloud.google.com/compute/docs/access/service-accounts for more information.
	JsonPath string `protobuf:"bytes,4,opt,name=jsonPath,proto3" json:"jsonPath,omitempty"`
	// The content to publish to the topic. Must be one of ALL or NOTIFICATIONS.
	Content string `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

Configuration for a Google Cloud Pub/Sub publisher.

func (*GooglePublisher) Descriptor deprecated 

func (*GooglePublisher) Descriptor() ([]byte, []int)

Deprecated: Use GooglePublisher.ProtoReflect.Descriptor instead.

func (*GooglePublisher) GetContent 

func (x *GooglePublisher) GetContent() string

func (*GooglePublisher) GetJsonPath 

func (x *GooglePublisher) GetJsonPath() string

func (*GooglePublisher) GetName 

func (x *GooglePublisher) GetName() string

func (*GooglePublisher) GetProject 

func (x *GooglePublisher) GetProject() string

func (*GooglePublisher) GetTopicName 

func (x *GooglePublisher) GetTopicName() string

func (*GooglePublisher) ProtoMessage 

func (*GooglePublisher) ProtoMessage()

func (*GooglePublisher) ProtoReflect 

func (x *GooglePublisher) ProtoReflect() protoreflect.Message

func (*GooglePublisher) Reset 

func (x *GooglePublisher) Reset()

func (*GooglePublisher) String 

func (x *GooglePublisher) String() string

type GoogleSubscriber 

type GoogleSubscriber struct {

	// The name of the subscriber account.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The name of the GCP project your subscription lives in.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// The name of the subscription to listen to. This identifier does not include
	// the name of the project, and must already be configured.
	SubscriptionName string `protobuf:"bytes,3,opt,name=subscriptionName,proto3" json:"subscriptionName,omitempty"`
	// The path to a JSON service account that Spinnaker will use as credentials.
	// This is only needed if Spinnaker is not deployed on a Google Compute Engine
	// VM, or needs permissions not afforded to the VM it is running on.
	// See https://cloud.google.com/compute/docs/access/service-accounts for more information.
	JsonPath string `protobuf:"bytes,4,opt,name=jsonPath,proto3" json:"jsonPath,omitempty"`
	// The acknowledgement deadline as configured on the Pub/Sub subscription.
	AckDeadlineSeconds int32 `protobuf:"varint,5,opt,name=ackDeadlineSeconds,proto3" json:"ackDeadlineSeconds,omitempty"`
	// The format of the incoming message. Used to translate the incoming message
	// into Spinnaker artifacts.
	MessageFormat MessageFormat `protobuf:"varint,6,opt,name=messageFormat,proto3,enum=proto.pubsub.MessageFormat" json:"messageFormat,omitempty"`
	// A path to a jinja template that specifies how artifacts from this pubsub system
	// are interpreted and transformed into Spinnaker artifacts. Only used if
	// messageFormat is set to CUSTOM.
	TemplatePath string `protobuf:"bytes,7,opt,name=templatePath,proto3" json:"templatePath,omitempty"`
	// contains filtered or unexported fields
}

Configuration for a Google Cloud Pub/Sub subscriber.

func (*GoogleSubscriber) Descriptor deprecated 

func (*GoogleSubscriber) Descriptor() ([]byte, []int)

Deprecated: Use GoogleSubscriber.ProtoReflect.Descriptor instead.

func (*GoogleSubscriber) GetAckDeadlineSeconds 

func (x *GoogleSubscriber) GetAckDeadlineSeconds() int32

func (*GoogleSubscriber) GetJsonPath 

func (x *GoogleSubscriber) GetJsonPath() string

func (*GoogleSubscriber) GetMessageFormat 

func (x *GoogleSubscriber) GetMessageFormat() MessageFormat

func (*GoogleSubscriber) GetName 

func (x *GoogleSubscriber) GetName() string

func (*GoogleSubscriber) GetProject 

func (x *GoogleSubscriber) GetProject() string

func (*GoogleSubscriber) GetSubscriptionName 

func (x *GoogleSubscriber) GetSubscriptionName() string

func (*GoogleSubscriber) GetTemplatePath 

func (x *GoogleSubscriber) GetTemplatePath() string

func (*GoogleSubscriber) ProtoMessage 

func (*GoogleSubscriber) ProtoMessage()

func (*GoogleSubscriber) ProtoReflect 

func (x *GoogleSubscriber) ProtoReflect() protoreflect.Message

func (*GoogleSubscriber) Reset 

func (x *GoogleSubscriber) Reset()

func (*GoogleSubscriber) String 

func (x *GoogleSubscriber) String() string

type MessageFormat 

type MessageFormat int32

Represents the format of an incoming pub/sub message. 

const (
	// Unspecified. Do not directly use, instead omit the field.
	MessageFormat_UNSPECIFIED MessageFormat = 0
	MessageFormat_CUSTOM      MessageFormat = 1
	MessageFormat_GCB         MessageFormat = 2
	MessageFormat_GCS         MessageFormat = 3
	MessageFormat_GCR         MessageFormat = 4
)

func (MessageFormat) Descriptor 

func (MessageFormat) Descriptor() protoreflect.EnumDescriptor

func (MessageFormat) Enum 

func (x MessageFormat) Enum() *MessageFormat

func (MessageFormat) EnumDescriptor deprecated 

func (MessageFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageFormat.Descriptor instead.

func (MessageFormat) Number 

func (x MessageFormat) Number() protoreflect.EnumNumber

func (MessageFormat) String 

func (x MessageFormat) String() string

func (MessageFormat) Type 

func (MessageFormat) Type() protoreflect.EnumType

type Pubsub 

type Pubsub struct {

	// Whether Pub/Sub is enabled.
	Enabled *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Configuration for the Google Cloud Pub/Sub integration.
	Google *Google `protobuf:"bytes,2,opt,name=google,proto3" json:"google,omitempty"`
	// contains filtered or unexported fields
}

Configuration for Pub/Sub integration.

func (*Pubsub) Descriptor deprecated 

func (*Pubsub) Descriptor() ([]byte, []int)

Deprecated: Use Pubsub.ProtoReflect.Descriptor instead.

func (*Pubsub) GetEnabled 

func (x *Pubsub) GetEnabled() *wrapperspb.BoolValue

func (*Pubsub) GetGoogle 

func (x *Pubsub) GetGoogle() *Google

func (*Pubsub) ProtoMessage 

func (*Pubsub) ProtoMessage()

func (*Pubsub) ProtoReflect 

func (x *Pubsub) ProtoReflect() protoreflect.Message

func (*Pubsub) Reset 

func (x *Pubsub) Reset()

func (*Pubsub) String 

func (x *Pubsub) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.