nats

Documentation

Overview

Package nats is a generated protocol buffer package.

It is generated from these files:

nats_streaming_filter.proto

It has these top-level messages:

NatsStreaming

Package nats is a generated protocol buffer package.

It is generated from these files:

service_properties.proto

It has these top-level messages:

ServiceProperties

Index

• Constants
• func EncodeServiceProperties(props ServiceProperties) *types.Struct
• type NatsStreaming
  • func (*NatsStreaming) Descriptor() ([]byte, []int)
  • func (m *NatsStreaming) GetCluster() string
  • func (m *NatsStreaming) GetMaxConnections() uint32
  • func (m *NatsStreaming) GetOpTimeout() *time.Duration
  • func (*NatsStreaming) ProtoMessage()
  • func (m *NatsStreaming) Reset()
  • func (m *NatsStreaming) String() string
• type Plugin
  • func (p *Plugin) HttpFilters(params *plugins.HttpFilterPluginParams) []plugins.StagedHttpFilter
  • func (p *Plugin) Init(options bootstrap.Options) error
  • func (p *Plugin) ParseFunctionSpec(params *plugins.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
  • func (p *Plugin) ProcessUpstream(params *plugins.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
• type ServiceProperties
  • func (*ServiceProperties) Descriptor() ([]byte, []int)
  • func (this *ServiceProperties) Equal(that interface{}) bool
  • func (m *ServiceProperties) GetClusterId() string
  • func (m *ServiceProperties) GetDiscoverPrefix() string
  • func (*ServiceProperties) ProtoMessage()
  • func (m *ServiceProperties) Reset()
  • func (m *ServiceProperties) String() string

Constants

const (
	ServiceTypeNatsStreaming = "nats-streaming"

	// ClusterId key for NATS streaming
	ClusterId = "cluster_id"
	// DiscoverPrefix key for NATS streaming
	DiscoverPrefix = "discover_prefix"

	// DefaultClusterId default NATS streaming cluster ID
	DefaultClusterId = "test-cluster"
	// DefaultDiscoverPrefix default NATS streaming discover prefix
	DefaultDiscoverPrefix = "_STAN.discover"
)

Functions

func EncodeServiceProperties

func EncodeServiceProperties(props ServiceProperties) *types.Struct

Types

type NatsStreaming

type NatsStreaming struct {
	Cluster        string         `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	MaxConnections uint32         `protobuf:"varint,2,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`
	OpTimeout      *time.Duration `protobuf:"bytes,3,opt,name=op_timeout,json=opTimeout,stdduration" json:"op_timeout,omitempty"`
}

[#proto-status: experimental]

func (*NatsStreaming) Descriptor

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

func (*NatsStreaming) GetCluster

func (m *NatsStreaming) GetCluster() string

func (*NatsStreaming) GetMaxConnections

func (m *NatsStreaming) GetMaxConnections() uint32

func (*NatsStreaming) GetOpTimeout

func (m *NatsStreaming) GetOpTimeout() *time.Duration

func (*NatsStreaming) ProtoMessage

func (*NatsStreaming) ProtoMessage()

func (*NatsStreaming) Reset

func (m *NatsStreaming) Reset()

func (*NatsStreaming) String

func (m *NatsStreaming) String() string

type Plugin

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

func (*Plugin) HttpFilters

func (p *Plugin) HttpFilters(params *plugins.HttpFilterPluginParams) []plugins.StagedHttpFilter

func (*Plugin) Init

func (p *Plugin) Init(options bootstrap.Options) error

func (*Plugin) ParseFunctionSpec

func (p *Plugin) ParseFunctionSpec(params *plugins.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)

func (*Plugin) ProcessUpstream

func (p *Plugin) ProcessUpstream(params *plugins.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error

type ServiceProperties

type ServiceProperties struct {
	// the cluster ID of the NATS-streaming service
	// defaults to `test-cluster`
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// the NATS-streaming discover prefix
	// defaults to `_STAN.discover`
	DiscoverPrefix string `protobuf:"bytes,2,opt,name=discover_prefix,json=discoverPrefix,proto3" json:"discover_prefix,omitempty"`
}

Service Properties for NATS-Streaming clusters Service Properties must be set to enable HTTP-to-NATS Message transformation via Gloo.

func (*ServiceProperties) Descriptor

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

func (*ServiceProperties) Equal

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

func (*ServiceProperties) GetClusterId

func (m *ServiceProperties) GetClusterId() string

func (*ServiceProperties) GetDiscoverPrefix

func (m *ServiceProperties) GetDiscoverPrefix() string

func (*ServiceProperties) ProtoMessage

func (*ServiceProperties) ProtoMessage()

func (*ServiceProperties) Reset

func (m *ServiceProperties) Reset()

func (*ServiceProperties) String

func (m *ServiceProperties) String() string