proxy

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: May 10, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetLogLevel 

func SetLogLevel(lvl logrus.Level)

SetLogLevel sets log level for logger.

func SetLogOutput 

func SetLogOutput(out io.Writer)

SetOutput sets log output for logger.

func SetLogger 

func SetLogger(l *logrus.Logger)

SetLogger sets logger.

Types

type BinapiClient 

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

func (*BinapiClient) CheckCompatiblity 

func (b *BinapiClient) CheckCompatiblity(msgs ...api.Message) error

func (*BinapiClient) Close 

func (b *BinapiClient) Close()

func (*BinapiClient) Invoke 

func (b *BinapiClient) Invoke(_ context.Context, request api.Message, reply api.Message) error

func (*BinapiClient) NewStream 

func (b *BinapiClient) NewStream(_ context.Context, _ ...api.StreamOption) (api.Stream, error)

func (*BinapiClient) SendMultiRequest 

func (b *BinapiClient) SendMultiRequest(msg api.Message) api.MultiRequestCtx

func (*BinapiClient) SendRequest 

func (b *BinapiClient) SendRequest(msg api.Message) api.RequestCtx

func (*BinapiClient) SetReplyTimeout 

func (b *BinapiClient) SetReplyTimeout(timeout time.Duration)

func (*BinapiClient) SubscribeNotification 

func (b *BinapiClient) SubscribeNotification(notifChan chan api.Message, event api.Message) (api.SubscriptionCtx, error)

type BinapiCompatibilityRequest 

type BinapiCompatibilityRequest struct {
	MsgNameCrcs []string
}

type BinapiCompatibilityResponse 

type BinapiCompatibilityResponse struct {
	CompatibleMsgs   map[string][]string
	IncompatibleMsgs map[string][]string
}

type BinapiRPC 

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

BinapiRPC is a RPC server for proxying client request to api.Channel or api.Stream.

func NewBinapiRPC 

func NewBinapiRPC(binapi adapter.VppAPI) (*BinapiRPC, error)

NewBinapiRPC returns new BinapiRPC to be used as RPC server proxying request to given api.Channel.

func (*BinapiRPC) CloseStream 

func (s *BinapiRPC) CloseStream(req RPCStreamReqResp, resp *RPCStreamReqResp) error

func (*BinapiRPC) Compatibility 

func (s *BinapiRPC) Compatibility(req BinapiCompatibilityRequest, resp *BinapiCompatibilityResponse) error

func (*BinapiRPC) Invoke 

func (s *BinapiRPC) Invoke(req BinapiRequest, resp *BinapiResponse) error

func (*BinapiRPC) NewAPIStream 

func (s *BinapiRPC) NewAPIStream(req RPCStreamReqResp, resp *RPCStreamReqResp) error

func (*BinapiRPC) ReceiveMessage 

func (s *BinapiRPC) ReceiveMessage(req RPCStreamReqResp, resp *RPCStreamReqResp) error

func (*BinapiRPC) SendMessage 

func (s *BinapiRPC) SendMessage(req RPCStreamReqResp, resp *RPCStreamReqResp) error

type BinapiRequest 

type BinapiRequest struct {
	Msg      api.Message
	IsMulti  bool
	ReplyMsg api.Message
	Timeout  time.Duration
}

type BinapiResponse 

type BinapiResponse struct {
	Msg  api.Message
	Msgs []api.Message
}

type Client 

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

func Connect 

func Connect(addr string) (*Client, error)

Connect dials remote proxy server on given address and returns new client if successful.

func (*Client) NewBinapiClient 

func (c *Client) NewBinapiClient() (*BinapiClient, error)

NewBinapiClient returns new BinapiClient which implements api.Channel.

func (*Client) NewStatsClient 

func (c *Client) NewStatsClient() (*StatsClient, error)

NewStatsClient returns new StatsClient which implements api.StatsProvider.

type RPCStream 

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

RPCStream is a stream for forwarding requests to BinapiRPC's stream.

func (*RPCStream) Close 

func (s *RPCStream) Close() error

func (*RPCStream) Context 

func (s *RPCStream) Context() context.Context

func (*RPCStream) RecvMsg 

func (s *RPCStream) RecvMsg() (api.Message, error)

func (*RPCStream) SendMsg 

func (s *RPCStream) SendMsg(msg api.Message) error

type RPCStreamReqResp 

type RPCStreamReqResp struct {
	ID  uint32
	Msg api.Message
}

type Server 

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

Server defines a proxy server that serves client requests to stats and binapi.

func NewServer 

func NewServer() (*Server, error)

func (*Server) ConnectBinapi 

func (p *Server) ConnectBinapi(binapi adapter.VppAPI) error

func (*Server) ConnectStats 

func (p *Server) ConnectStats(stats adapter.StatsAPI) error

func (*Server) DisconnectBinapi 

func (p *Server) DisconnectBinapi()

func (*Server) DisconnectStats 

func (p *Server) DisconnectStats()

func (*Server) ListenAndServe 

func (p *Server) ListenAndServe(addr string) error

func (*Server) ServeCodec 

func (p *Server) ServeCodec(codec rpc.ServerCodec)

func (*Server) ServeConn 

func (p *Server) ServeConn(conn io.ReadWriteCloser)

func (*Server) ServeHTTP 

func (p *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

type StatsClient 

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

func (*StatsClient) GetBufferStats 

func (s *StatsClient) GetBufferStats(bufStats *api.BufferStats) error

func (*StatsClient) GetErrorStats 

func (s *StatsClient) GetErrorStats(errStats *api.ErrorStats) error

func (*StatsClient) GetInterfaceStats 

func (s *StatsClient) GetInterfaceStats(ifaceStats *api.InterfaceStats) error

func (*StatsClient) GetMemoryStats 

func (s *StatsClient) GetMemoryStats(memStats *api.MemoryStats) error

func (*StatsClient) GetNodeStats 

func (s *StatsClient) GetNodeStats(nodeStats *api.NodeStats) error

func (*StatsClient) GetSystemStats 

func (s *StatsClient) GetSystemStats(sysStats *api.SystemStats) error

type StatsRPC 

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

StatsRPC is a RPC server for proxying client request to api.StatsProvider.

func NewStatsRPC 

func NewStatsRPC(stats adapter.StatsAPI) (*StatsRPC, error)

NewStatsRPC returns new StatsRPC to be used as RPC server proxying request to given api.StatsProvider.

func (*StatsRPC) GetStats 

func (s *StatsRPC) GetStats(req StatsRequest, resp *StatsResponse) error

type StatsRequest 

type StatsRequest struct {
	StatsType string
}

type StatsResponse 

type StatsResponse struct {
	SysStats   *api.SystemStats
	NodeStats  *api.NodeStats
	IfaceStats *api.InterfaceStats
	ErrStats   *api.ErrorStats
	BufStats   *api.BufferStats
	MemStats   *api.MemoryStats
}

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.