proto

package
v0.10.5 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_GCEInstances_ReEvalSec int32 = 300
View Source 
const Default_ProviderConfig_ApiVersion string = "v1"
View Source 
const Default_PubSubMessages_Subscription_SeekBackDurationSec int32 = 3600
View Source 
const Default_RTCVariables_RTCConfig_ReEvalSec int32 = 10

Variables

This section is empty.

Functions

This section is empty.

Types

type GCEInstances 

type GCEInstances struct {
	// Zone filter, e.g. zone_filter: "us-east1-*" for all zones in us-east1
	// region.
	ZoneFilter *string `protobuf:"bytes,1,opt,name=zone_filter,json=zoneFilter" json:"zone_filter,omitempty"`
	// How often resources should be evaluated/expanded.
	ReEvalSec            *int32   `protobuf:"varint,98,opt,name=re_eval_sec,json=reEvalSec,def=300" json:"re_eval_sec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCEInstances) Descriptor 

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

func (*GCEInstances) GetReEvalSec 

func (m *GCEInstances) GetReEvalSec() int32

func (*GCEInstances) GetZoneFilter 

func (m *GCEInstances) GetZoneFilter() string

func (*GCEInstances) ProtoMessage 

func (*GCEInstances) ProtoMessage()

func (*GCEInstances) Reset 

func (m *GCEInstances) Reset()

func (*GCEInstances) String 

func (m *GCEInstances) String() string

func (*GCEInstances) XXX_DiscardUnknown 

func (m *GCEInstances) XXX_DiscardUnknown()

func (*GCEInstances) XXX_Marshal 

func (m *GCEInstances) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCEInstances) XXX_Merge 

func (m *GCEInstances) XXX_Merge(src proto.Message)

func (*GCEInstances) XXX_Size 

func (m *GCEInstances) XXX_Size() int

func (*GCEInstances) XXX_Unmarshal 

func (m *GCEInstances) XXX_Unmarshal(b []byte) error

type ProviderConfig 

type ProviderConfig struct {
	// GCP projects. If running on GCE, it defaults to the local project.
	Project []string `protobuf:"bytes,1,rep,name=project" json:"project,omitempty"`
	// GCE instances discovery options. This field should be declared for the GCE
	// instances discovery to be enabled.
	GceInstances *GCEInstances `protobuf:"bytes,2,opt,name=gce_instances,json=gceInstances" json:"gce_instances,omitempty"`
	// Regional forwarding rules discovery options. This field should be declared
	// for the regional forwarding rules discovery to be enabled.
	// NOTE: This is not supported yet.
	RegionalForwardingRules *RegionalForwardingRules `protobuf:"bytes,3,opt,name=regional_forwarding_rules,json=regionalForwardingRules" json:"regional_forwarding_rules,omitempty"`
	// RTC variables discovery options.
	RtcVariables *RTCVariables `protobuf:"bytes,4,opt,name=rtc_variables,json=rtcVariables" json:"rtc_variables,omitempty"`
	// PubSub messages discovery options.
	PubsubMessages *PubSubMessages `protobuf:"bytes,5,opt,name=pubsub_messages,json=pubsubMessages" json:"pubsub_messages,omitempty"`
	// Compute API version.
	ApiVersion           *string  `protobuf:"bytes,99,opt,name=api_version,json=apiVersion,def=v1" json:"api_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GCP provider config.

func (*ProviderConfig) Descriptor 

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

func (*ProviderConfig) GetApiVersion 

func (m *ProviderConfig) GetApiVersion() string

func (*ProviderConfig) GetGceInstances 

func (m *ProviderConfig) GetGceInstances() *GCEInstances

func (*ProviderConfig) GetProject 

func (m *ProviderConfig) GetProject() []string

func (*ProviderConfig) GetPubsubMessages 

func (m *ProviderConfig) GetPubsubMessages() *PubSubMessages

func (*ProviderConfig) GetRegionalForwardingRules 

func (m *ProviderConfig) GetRegionalForwardingRules() *RegionalForwardingRules

func (*ProviderConfig) GetRtcVariables 

func (m *ProviderConfig) GetRtcVariables() *RTCVariables

func (*ProviderConfig) ProtoMessage 

func (*ProviderConfig) ProtoMessage()

func (*ProviderConfig) Reset 

func (m *ProviderConfig) Reset()

func (*ProviderConfig) String 

func (m *ProviderConfig) String() string

func (*ProviderConfig) XXX_DiscardUnknown 

func (m *ProviderConfig) XXX_DiscardUnknown()

func (*ProviderConfig) XXX_Marshal 

func (m *ProviderConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProviderConfig) XXX_Merge 

func (m *ProviderConfig) XXX_Merge(src proto.Message)

func (*ProviderConfig) XXX_Size 

func (m *ProviderConfig) XXX_Size() int

func (*ProviderConfig) XXX_Unmarshal 

func (m *ProviderConfig) XXX_Unmarshal(b []byte) error

type PubSubMessages 

type PubSubMessages struct {
	Subscription []*PubSubMessages_Subscription `protobuf:"bytes,1,rep,name=subscription" json:"subscription,omitempty"`
	// Only for testing.
	ApiEndpoint          *string  `protobuf:"bytes,2,opt,name=api_endpoint,json=apiEndpoint" json:"api_endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Runtime configurator variables.

func (*PubSubMessages) Descriptor 

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

func (*PubSubMessages) GetApiEndpoint 

func (m *PubSubMessages) GetApiEndpoint() string

func (*PubSubMessages) GetSubscription 

func (m *PubSubMessages) GetSubscription() []*PubSubMessages_Subscription

func (*PubSubMessages) ProtoMessage 

func (*PubSubMessages) ProtoMessage()

func (*PubSubMessages) Reset 

func (m *PubSubMessages) Reset()

func (*PubSubMessages) String 

func (m *PubSubMessages) String() string

func (*PubSubMessages) XXX_DiscardUnknown 

func (m *PubSubMessages) XXX_DiscardUnknown()

func (*PubSubMessages) XXX_Marshal 

func (m *PubSubMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubMessages) XXX_Merge 

func (m *PubSubMessages) XXX_Merge(src proto.Message)

func (*PubSubMessages) XXX_Size 

func (m *PubSubMessages) XXX_Size() int

func (*PubSubMessages) XXX_Unmarshal 

func (m *PubSubMessages) XXX_Unmarshal(b []byte) error

type PubSubMessages_Subscription 

type PubSubMessages_Subscription struct {
	// Subscription name. If it doesn't exist already, we try to create one.
	Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	// Topic name. This is used to create the subscription if it doesn't exist
	// already.
	TopicName *string `protobuf:"bytes,2,opt,name=topic_name,json=topicName" json:"topic_name,omitempty"`
	// If subscription already exists, how far back to seek back on restart.
	// Note that duplicate data is fine as we filter by publish time.
	SeekBackDurationSec  *int32   `protobuf:"varint,3,opt,name=seek_back_duration_sec,json=seekBackDurationSec,def=3600" json:"seek_back_duration_sec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubSubMessages_Subscription) Descriptor 

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

func (*PubSubMessages_Subscription) GetName 

func (m *PubSubMessages_Subscription) GetName() string

func (*PubSubMessages_Subscription) GetSeekBackDurationSec 

func (m *PubSubMessages_Subscription) GetSeekBackDurationSec() int32

func (*PubSubMessages_Subscription) GetTopicName 

func (m *PubSubMessages_Subscription) GetTopicName() string

func (*PubSubMessages_Subscription) ProtoMessage 

func (*PubSubMessages_Subscription) ProtoMessage()

func (*PubSubMessages_Subscription) Reset 

func (m *PubSubMessages_Subscription) Reset()

func (*PubSubMessages_Subscription) String 

func (m *PubSubMessages_Subscription) String() string

func (*PubSubMessages_Subscription) XXX_DiscardUnknown 

func (m *PubSubMessages_Subscription) XXX_DiscardUnknown()

func (*PubSubMessages_Subscription) XXX_Marshal 

func (m *PubSubMessages_Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubMessages_Subscription) XXX_Merge 

func (m *PubSubMessages_Subscription) XXX_Merge(src proto.Message)

func (*PubSubMessages_Subscription) XXX_Size 

func (m *PubSubMessages_Subscription) XXX_Size() int

func (*PubSubMessages_Subscription) XXX_Unmarshal 

func (m *PubSubMessages_Subscription) XXX_Unmarshal(b []byte) error

type RTCVariables 

type RTCVariables struct {
	RtcConfig            []*RTCVariables_RTCConfig `protobuf:"bytes,1,rep,name=rtc_config,json=rtcConfig" json:"rtc_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

Runtime configurator variables.

func (*RTCVariables) Descriptor 

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

func (*RTCVariables) GetRtcConfig 

func (m *RTCVariables) GetRtcConfig() []*RTCVariables_RTCConfig

func (*RTCVariables) ProtoMessage 

func (*RTCVariables) ProtoMessage()

func (*RTCVariables) Reset 

func (m *RTCVariables) Reset()

func (*RTCVariables) String 

func (m *RTCVariables) String() string

func (*RTCVariables) XXX_DiscardUnknown 

func (m *RTCVariables) XXX_DiscardUnknown()

func (*RTCVariables) XXX_Marshal 

func (m *RTCVariables) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RTCVariables) XXX_Merge 

func (m *RTCVariables) XXX_Merge(src proto.Message)

func (*RTCVariables) XXX_Size 

func (m *RTCVariables) XXX_Size() int

func (*RTCVariables) XXX_Unmarshal 

func (m *RTCVariables) XXX_Unmarshal(b []byte) error

type RTCVariables_RTCConfig 

type RTCVariables_RTCConfig struct {
	Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	// How often RTC variables should be evaluated/expanded.
	ReEvalSec            *int32   `protobuf:"varint,2,opt,name=re_eval_sec,json=reEvalSec,def=10" json:"re_eval_sec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RTCVariables_RTCConfig) Descriptor 

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

func (*RTCVariables_RTCConfig) GetName 

func (m *RTCVariables_RTCConfig) GetName() string

func (*RTCVariables_RTCConfig) GetReEvalSec 

func (m *RTCVariables_RTCConfig) GetReEvalSec() int32

func (*RTCVariables_RTCConfig) ProtoMessage 

func (*RTCVariables_RTCConfig) ProtoMessage()

func (*RTCVariables_RTCConfig) Reset 

func (m *RTCVariables_RTCConfig) Reset()

func (*RTCVariables_RTCConfig) String 

func (m *RTCVariables_RTCConfig) String() string

func (*RTCVariables_RTCConfig) XXX_DiscardUnknown 

func (m *RTCVariables_RTCConfig) XXX_DiscardUnknown()

func (*RTCVariables_RTCConfig) XXX_Marshal 

func (m *RTCVariables_RTCConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RTCVariables_RTCConfig) XXX_Merge 

func (m *RTCVariables_RTCConfig) XXX_Merge(src proto.Message)

func (*RTCVariables_RTCConfig) XXX_Size 

func (m *RTCVariables_RTCConfig) XXX_Size() int

func (*RTCVariables_RTCConfig) XXX_Unmarshal 

func (m *RTCVariables_RTCConfig) XXX_Unmarshal(b []byte) error

type RegionalForwardingRules 

type RegionalForwardingRules struct {
	// Region filter, e.g. "region_filter:europe-*"
	RegionFilter         *string  `protobuf:"bytes,1,opt,name=region_filter,json=regionFilter" json:"region_filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionalForwardingRules) Descriptor 

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

func (*RegionalForwardingRules) GetRegionFilter 

func (m *RegionalForwardingRules) GetRegionFilter() string

func (*RegionalForwardingRules) ProtoMessage 

func (*RegionalForwardingRules) ProtoMessage()

func (*RegionalForwardingRules) Reset 

func (m *RegionalForwardingRules) Reset()

func (*RegionalForwardingRules) String 

func (m *RegionalForwardingRules) String() string

func (*RegionalForwardingRules) XXX_DiscardUnknown 

func (m *RegionalForwardingRules) XXX_DiscardUnknown()

func (*RegionalForwardingRules) XXX_Marshal 

func (m *RegionalForwardingRules) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionalForwardingRules) XXX_Merge 

func (m *RegionalForwardingRules) XXX_Merge(src proto.Message)

func (*RegionalForwardingRules) XXX_Size 

func (m *RegionalForwardingRules) XXX_Size() int

func (*RegionalForwardingRules) XXX_Unmarshal 

func (m *RegionalForwardingRules) XXX_Unmarshal(b []byte) error

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.