proxy

Documentation

Index

• Variables
• func InitStreamStore()
• func NewBufferPool() httputil.BufferPool
• func NewEtcdGrpcProxy(etcdConf cfg.Etcd) *grpcProxy
• func NewHTTPProxy() http.Handler
• type GrpcEtcdConfigWorker
  • func NewProxyGrpcConfigWorker() *GrpcEtcdConfigWorker
  • func (worker *GrpcEtcdConfigWorker) Run() error
  • func (worker *GrpcEtcdConfigWorker) Stop() error
• type GrpcEtcdRegisterWorker
  • func NewProxyGrpcRegisterWorker() *GrpcEtcdRegisterWorker
  • func (worker *GrpcEtcdRegisterWorker) Run() error
  • func (worker *GrpcEtcdRegisterWorker) 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(etcdConf cfg.Etcd) *grpcProxy

NewEtcdGrpcProxy ..

func NewHTTPProxy

func NewHTTPProxy() http.Handler

NewHTTPProxy ..

Types

type GrpcEtcdConfigWorker

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

GrpcEtcdConfigWorker ..

func NewProxyGrpcConfigWorker

func NewProxyGrpcConfigWorker() *GrpcEtcdConfigWorker

NewProxyGrpcConfigWorker ..

func (*GrpcEtcdConfigWorker) Run

func (worker *GrpcEtcdConfigWorker) Run() error

func (*GrpcEtcdConfigWorker) Stop

func (worker *GrpcEtcdConfigWorker) Stop() error

type GrpcEtcdRegisterWorker

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

GrpcEtcdRegisterWorker ..

func NewProxyGrpcRegisterWorker

func NewProxyGrpcRegisterWorker() *GrpcEtcdRegisterWorker

NewProxyGrpcRegisterWorker ..

func (*GrpcEtcdRegisterWorker) Run

func (worker *GrpcEtcdRegisterWorker) Run() error

func (*GrpcEtcdRegisterWorker) Stop

func (worker *GrpcEtcdRegisterWorker) 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