Documentation ¶
Overview ¶
Package natsstreaming is a generated protocol buffer package.
It is generated from these files:
nats_streaming_filter.proto
It has these top-level messages:
NatsStreaming
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() *google_protobuf.Duration
- func (*NatsStreaming) ProtoMessage()
- func (m *NatsStreaming) Reset()
- func (m *NatsStreaming) String() string
- type Plugin
- func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies
- func (p *Plugin) HttpFilters(params *plugin.FilterPluginParams) []plugin.StagedFilter
- func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
- func (p *Plugin) ProcessUpstream(params *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
- type ServiceProperties
Constants ¶
View Source
const (
ServiceTypeNatsStreaming = "nats-streaming"
)
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 *google_protobuf.Duration `protobuf:"bytes,3,opt,name=op_timeout,json=opTimeout" 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() *google_protobuf.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) GetDependencies ¶
func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies
func (*Plugin) HttpFilters ¶
func (p *Plugin) HttpFilters(params *plugin.FilterPluginParams) []plugin.StagedFilter
func (*Plugin) ParseFunctionSpec ¶
func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
func (*Plugin) ProcessUpstream ¶
type ServiceProperties ¶
Click to show internal directories.
Click to hide internal directories.