consul

Documentation

Index

• type UpstreamSpec
  • func (*UpstreamSpec) Descriptor() ([]byte, []int)
  • func (this *UpstreamSpec) Equal(that interface{}) bool
  • func (m *UpstreamSpec) GetConnectEnabled() bool
  • func (m *UpstreamSpec) GetDataCenters() []string
  • func (m *UpstreamSpec) GetInstanceBlacklistTags() []string
  • func (m *UpstreamSpec) GetInstanceTags() []string
  • func (m *UpstreamSpec) GetServiceName() string
  • func (m *UpstreamSpec) GetServiceSpec() *options.ServiceSpec
  • func (m *UpstreamSpec) GetServiceTags() []string
  • func (m *UpstreamSpec) GetSubsetTags() []string
  • func (m *UpstreamSpec) Hash(hasher hash.Hash64) (uint64, error)
  • func (*UpstreamSpec) ProtoMessage()
  • func (m *UpstreamSpec) Reset()
  • func (m *UpstreamSpec) String() string
  • func (m *UpstreamSpec) XXX_DiscardUnknown()
  • func (m *UpstreamSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UpstreamSpec) XXX_Merge(src proto.Message)
  • func (m *UpstreamSpec) XXX_Size() int
  • func (m *UpstreamSpec) XXX_Unmarshal(b []byte) error

Types

type UpstreamSpec

type UpstreamSpec struct {
	// The name of the Consul Service
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Deprecated: This field was renamed to subset_tags. If subset_tags is used, this field is
	// ignored. Otherwise, the behavior is the same as subset_tags field below.
	ServiceTags []string `protobuf:"bytes,2,rep,name=service_tags,json=serviceTags,proto3" json:"service_tags,omitempty"`
	// Gloo will segment instances based off of these tags. This allows you to set routes that route
	// to a subset of the instances of the service
	SubsetTags []string `protobuf:"bytes,6,rep,name=subset_tags,json=subsetTags,proto3" json:"subset_tags,omitempty"`
	// The list of service tags Gloo should search for on a service instance
	// before deciding whether or not to include the instance as part of this
	// upstream. Empty list means that all service instances with the same service name will be
	// included. When not empty, only service instances that match all of the tags (subset match) will be selected
	// for this upstream.
	InstanceTags []string `protobuf:"bytes,7,rep,name=instance_tags,json=instanceTags,proto3" json:"instance_tags,omitempty"`
	// The opposite of instanceTags, this is a list of service tags that gloo should ensure are not
	// in a service instance before including it in an upstream.
	InstanceBlacklistTags []string `` /* 126-byte string literal not displayed */
	// An optional Service Spec describing the service listening at this address
	ServiceSpec *options.ServiceSpec `protobuf:"bytes,3,opt,name=service_spec,json=serviceSpec,proto3" json:"service_spec,omitempty"`
	// Is this consul service connect enabled.
	ConnectEnabled bool `protobuf:"varint,4,opt,name=connect_enabled,json=connectEnabled,proto3" json:"connect_enabled,omitempty"`
	// The data centers in which the service instance represented by this upstream is registered.
	DataCenters          []string `protobuf:"bytes,5,rep,name=data_centers,json=dataCenters,proto3" json:"data_centers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Upstream Spec for Consul Upstreams consul Upstreams represent a set of one or more addressable pods for a consul Service the Gloo consul Upstream maps to a single service port. Because consul Services support multiple ports, Gloo requires that a different upstream be created for each port consul Upstreams are typically generated automatically by Gloo from the consul API

func (*UpstreamSpec) Descriptor

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

func (*UpstreamSpec) Equal

func (this *UpstreamSpec) Equal(that interface{}) bool

func (*UpstreamSpec) GetConnectEnabled

func (m *UpstreamSpec) GetConnectEnabled() bool

func (*UpstreamSpec) GetDataCenters

func (m *UpstreamSpec) GetDataCenters() []string

func (*UpstreamSpec) GetInstanceBlacklistTags

func (m *UpstreamSpec) GetInstanceBlacklistTags() []string

func (*UpstreamSpec) GetInstanceTags

func (m *UpstreamSpec) GetInstanceTags() []string

func (*UpstreamSpec) GetServiceName

func (m *UpstreamSpec) GetServiceName() string

func (*UpstreamSpec) GetServiceSpec

func (m *UpstreamSpec) GetServiceSpec() *options.ServiceSpec

func (*UpstreamSpec) GetServiceTags

func (m *UpstreamSpec) GetServiceTags() []string

func (*UpstreamSpec) GetSubsetTags

func (m *UpstreamSpec) GetSubsetTags() []string

func (*UpstreamSpec) Hash

func (m *UpstreamSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*UpstreamSpec) ProtoMessage

func (*UpstreamSpec) ProtoMessage()

func (*UpstreamSpec) Reset

func (m *UpstreamSpec) Reset()

func (*UpstreamSpec) String

func (m *UpstreamSpec) String() string

func (*UpstreamSpec) XXX_DiscardUnknown

func (m *UpstreamSpec) XXX_DiscardUnknown()

func (*UpstreamSpec) XXX_Marshal

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

func (*UpstreamSpec) XXX_Merge

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

func (*UpstreamSpec) XXX_Size

func (m *UpstreamSpec) XXX_Size() int

func (*UpstreamSpec) XXX_Unmarshal

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