proxy

Documentation

Index

• Variables
• func InitStreamStore()
• func NewBufferPool() httputil.BufferPool
• func NewEtcdGrpcProxy() *grpcProxy
• func NewHTTPProxy() http.Handler
• type GrpcWorker
  • func NewProxyGrpcWorker() *GrpcWorker
  • func (worker *GrpcWorker) Run() error
  • func (worker *GrpcWorker) Stop() error
• type HttpWorker
  • func NewProxyHttpWorker() *HttpWorker
  • func (worker *HttpWorker) Run() error
  • func (worker *HttpWorker) Stop() error

Variables

var StreamStore *store

Functions

func InitStreamStore

func InitStreamStore()

func NewBufferPool

func NewBufferPool() httputil.BufferPool

func NewEtcdGrpcProxy

func NewEtcdGrpcProxy() *grpcProxy

NewEtcdGrpcProxy ..

func NewHTTPProxy

func NewHTTPProxy() http.Handler

NewHTTPProxy ..

Types

type GrpcWorker

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

func NewProxyGrpcWorker

func NewProxyGrpcWorker() *GrpcWorker

func (*GrpcWorker) Run

func (worker *GrpcWorker) Run() error

func (*GrpcWorker) Stop

func (worker *GrpcWorker) Stop() error

type HttpWorker

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

func NewProxyHttpWorker

func NewProxyHttpWorker() *HttpWorker

func (*HttpWorker) Run

func (worker *HttpWorker) Run() error

Run ..

func (*HttpWorker) Stop

func (worker *HttpWorker) Stop() error

Stop the worker