network

package
v1.30.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 11 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ref: https://golang.org/cmd/cgo/
	// The size of any C type T is available as C.sizeof_T, as in C.sizeof_struct_stat.
	CULLSize uintptr = C.sizeof_ulonglong

	ErrDupRequestKey = errors.New("dup request key")

	DownstreamFilters = &DownstreamFilterMap{}
	UpstreamFilters   = &UpstreamFilterMap{}
)

Functions

func CreateUpstreamConn 

func CreateUpstreamConn(addr string, filter api.UpstreamFilter)

func RegisterNetworkFilterConfigFactory 

func RegisterNetworkFilterConfigFactory(name string, factory ConfigFactory)

func RegisterNetworkFilterConfigParser 

func RegisterNetworkFilterConfigParser(parser ConfigParser)

func SetCgoAPI 

func SetCgoAPI(apiImpl api.NetworkCAPI)

Types

type ConfigFactory 

type ConfigFactory interface {
	CreateFactoryFromConfig(config interface{}) FilterFactory
}

func GetNetworkFilterConfigFactory 

func GetNetworkFilterConfigFactory(name string) ConfigFactory

type ConfigParser 

type ConfigParser interface {
	// TODO: should return error when the config is invalid.
	ParseConfig(any *anypb.Any) interface{}
}

func GetNetworkFilterConfigParser 

func GetNetworkFilterConfigParser() ConfigParser

type DownstreamFilterMap 

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

func (*DownstreamFilterMap) Clear 

func (f *DownstreamFilterMap) Clear()

func (*DownstreamFilterMap) DeleteFilter 

func (f *DownstreamFilterMap) DeleteFilter(key uint64)

func (*DownstreamFilterMap) GetFilter 

func (f *DownstreamFilterMap) GetFilter(key uint64) api.DownstreamFilter

func (*DownstreamFilterMap) GetFilterWrapper 

func (f *DownstreamFilterMap) GetFilterWrapper(key uint64) *downstreamFilterWrapper

func (*DownstreamFilterMap) StoreFilter 

func (f *DownstreamFilterMap) StoreFilter(key uint64, filter *downstreamFilterWrapper) error

type FilterFactory 

type FilterFactory interface {
	CreateFilter(cb api.ConnectionCallback) api.DownstreamFilter
}

type UpstreamFilterMap 

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

func (*UpstreamFilterMap) Clear 

func (f *UpstreamFilterMap) Clear()

func (*UpstreamFilterMap) DeleteFilterByConnID added in v1.28.0 

func (f *UpstreamFilterMap) DeleteFilterByConnID(key uint64)

func (*UpstreamFilterMap) DeleteFilterByWrapper added in v1.28.0 

func (f *UpstreamFilterMap) DeleteFilterByWrapper(key uint64)

func (*UpstreamFilterMap) GetFilterByConnID added in v1.28.0 

func (f *UpstreamFilterMap) GetFilterByConnID(key uint64) api.UpstreamFilter

func (*UpstreamFilterMap) GetFilterByWrapper added in v1.28.0 

func (f *UpstreamFilterMap) GetFilterByWrapper(key uint64) api.UpstreamFilter

func (*UpstreamFilterMap) StoreFilterByConnID added in v1.28.0 

func (f *UpstreamFilterMap) StoreFilterByConnID(key uint64, filter api.UpstreamFilter) error

func (*UpstreamFilterMap) StoreFilterByWrapper added in v1.28.0 

func (f *UpstreamFilterMap) StoreFilterByWrapper(key uint64, filter api.UpstreamFilter) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.