proxy

Feb 26, 2025

Changes in this version

+ const MetricsSubsystem

+ var RequestInfo = &avsi.RequestInfo

+ func NewAppConnDvs(appConn avsicli.Client, metrics *Metrics) *appConnDvs

+ type AppConnDvs interface

+ Error func() error

+ ProcessDVSRequest func(context.Context, *types.RequestProcessDVSRequest) (*types.ResponseProcessDVSRequest, error)

+ ProcessDVSResponse func(context.Context, *types.RequestProcessDVSResponse) (*types.ResponseProcessDVSResponse, error)

+ type AppConnQuery interface

+ Echo func(context.Context, string) (*types.ResponseEcho, error)

+ Error func() error

+ Info func(context.Context, *types.RequestInfo) (*types.ResponseInfo, error)

+ Query func(context.Context, *types.RequestQuery) (*types.ResponseQuery, error)

+ func NewAppConnQuery(appConn avsicli.Client, metrics *Metrics) AppConnQuery

+ type AppConns interface

+ Dvs func() AppConnDvs

+ Query func() AppConnQuery

+ func NewAppConns(clientCreator ClientCreator, metrics *Metrics) AppConns

+ func NewMultiAppConn(clientCreator ClientCreator, metrics *Metrics) AppConns

+ type ClientCreator interface

+ NewAVSIClient func() (avsicli.Client, error)

+ func DefaultClientCreator(addr, transport, dbDir string) ClientCreator

+ func NewConnSyncLocalClientCreator(app types.Application) ClientCreator

+ func NewLocalClientCreator(app types.Application) ClientCreator

+ func NewRemoteClientCreator(addr, transport string, mustConnect bool) ClientCreator

+ type Metrics struct

+ MethodTimingSeconds metrics.Histogram

+ func NopMetrics() *Metrics

+ func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics