natsstreaming

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

const (
	ServiceTypeNatsStreaming = "nats-streaming"
)

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

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

type ServiceProperties

type ServiceProperties struct {
	ClusterID      string `json:"cluster_id"`
	DiscoverPrefix string `json:"discover_prefix"`
}