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 ¶
View Source
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" )
Variables ¶
This section is empty.
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) ParseFunctionSpec ¶
func (p *Plugin) ParseFunctionSpec(params *plugins.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
func (*Plugin) ProcessUpstream ¶
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
Click to show internal directories.
Click to hide internal directories.