Upf

package
v0.0.0-...-1bf0fd6 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

This section is empty.

Types

type PortStats 

type PortStats struct {
	RxPktCnt              []int32   `thrift:"rxPktCnt,1,required" db:"rxPktCnt" json:"rxPktCnt"`
	RxPktDropCnt          []int32   `thrift:"rxPktDropCnt,2,required" db:"rxPktDropCnt" json:"rxPktDropCnt"`
	TxNQfiPktCnt          int32     `thrift:"txNQfiPktCnt,3,required" db:"txNQfiPktCnt" json:"txNQfiPktCnt"`
	TxNQfiPktDropCnt      int32     `thrift:"txNQfiPktDropCnt,4,required" db:"txNQfiPktDropCnt" json:"txNQfiPktDropCnt"`
	TxPktCnt              []int32   `thrift:"txPktCnt,5,required" db:"txPktCnt" json:"txPktCnt"`
	TxPktDropCnt          []int32   `thrift:"txPktDropCnt,6,required" db:"txPktDropCnt" json:"txPktDropCnt"`
	DropperPkts           [][]int32 `thrift:"dropperPkts,7,required" db:"dropperPkts" json:"dropperPkts"`
	DropperDrops          [][]int32 `thrift:"dropperDrops,8,required" db:"dropperDrops" json:"dropperDrops"`
	SchedulerQDropCnt     []int32   `thrift:"schedulerQDropCnt,9,required" db:"schedulerQDropCnt" json:"schedulerQDropCnt"`
	NffGoSchedulerDropCnt int32     `thrift:"nffGoSchedulerDropCnt,10,required" db:"nffGoSchedulerDropCnt" json:"nffGoSchedulerDropCnt"`
	ClassifierDropCnt     int32     `thrift:"classifierDropCnt,11,required" db:"classifierDropCnt" json:"classifierDropCnt"`
	WorkerDropCnt         int32     `thrift:"workerDropCnt,12,required" db:"workerDropCnt" json:"workerDropCnt"`
}

Attributes:

  • RxPktCnt
  • RxPktDropCnt
  • TxNQfiPktCnt
  • TxNQfiPktDropCnt
  • TxPktCnt
  • TxPktDropCnt
  • DropperPkts
  • DropperDrops
  • SchedulerQDropCnt
  • NffGoSchedulerDropCnt
  • ClassifierDropCnt
  • WorkerDropCnt
var StatsResponse_Stats_DEFAULT *PortStats

func NewPortStats 

func NewPortStats() *PortStats

func (*PortStats) Equals 

func (p *PortStats) Equals(other *PortStats) bool

func (*PortStats) GetClassifierDropCnt 

func (p *PortStats) GetClassifierDropCnt() int32

func (*PortStats) GetDropperDrops 

func (p *PortStats) GetDropperDrops() [][]int32

func (*PortStats) GetDropperPkts 

func (p *PortStats) GetDropperPkts() [][]int32

func (*PortStats) GetNffGoSchedulerDropCnt 

func (p *PortStats) GetNffGoSchedulerDropCnt() int32

func (*PortStats) GetRxPktCnt 

func (p *PortStats) GetRxPktCnt() []int32

func (*PortStats) GetRxPktDropCnt 

func (p *PortStats) GetRxPktDropCnt() []int32

func (*PortStats) GetSchedulerQDropCnt 

func (p *PortStats) GetSchedulerQDropCnt() []int32

func (*PortStats) GetTxNQfiPktCnt 

func (p *PortStats) GetTxNQfiPktCnt() int32

func (*PortStats) GetTxNQfiPktDropCnt 

func (p *PortStats) GetTxNQfiPktDropCnt() int32

func (*PortStats) GetTxPktCnt 

func (p *PortStats) GetTxPktCnt() []int32

func (*PortStats) GetTxPktDropCnt 

func (p *PortStats) GetTxPktDropCnt() []int32

func (*PortStats) GetWorkerDropCnt 

func (p *PortStats) GetWorkerDropCnt() int32

func (*PortStats) Read 

func (p *PortStats) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField1 

func (p *PortStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField10 

func (p *PortStats) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField11 

func (p *PortStats) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField12 

func (p *PortStats) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField2 

func (p *PortStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField3 

func (p *PortStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField4 

func (p *PortStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField5 

func (p *PortStats) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField6 

func (p *PortStats) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField7 

func (p *PortStats) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField8 

func (p *PortStats) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) ReadField9 

func (p *PortStats) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*PortStats) String 

func (p *PortStats) String() string

func (*PortStats) Write 

func (p *PortStats) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatsResponse 

type StatsResponse struct {
	ErrCode int32      `thrift:"errCode,1,required" db:"errCode" json:"errCode"`
	ErrMsg  string     `thrift:"errMsg,2,required" db:"errMsg" json:"errMsg"`
	Stats   *PortStats `thrift:"stats,3,required" db:"stats" json:"stats"`
}

Attributes:

  • ErrCode
  • ErrMsg
  • Stats
var UpfServiceGetStatsResult_Success_DEFAULT *StatsResponse

func NewStatsResponse 

func NewStatsResponse() *StatsResponse

func (*StatsResponse) Equals 

func (p *StatsResponse) Equals(other *StatsResponse) bool

func (*StatsResponse) GetErrCode 

func (p *StatsResponse) GetErrCode() int32

func (*StatsResponse) GetErrMsg 

func (p *StatsResponse) GetErrMsg() string

func (*StatsResponse) GetStats 

func (p *StatsResponse) GetStats() *PortStats

func (*StatsResponse) IsSetStats 

func (p *StatsResponse) IsSetStats() bool

func (*StatsResponse) Read 

func (p *StatsResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatsResponse) ReadField1 

func (p *StatsResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*StatsResponse) ReadField2 

func (p *StatsResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*StatsResponse) ReadField3 

func (p *StatsResponse) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*StatsResponse) String 

func (p *StatsResponse) String() string

func (*StatsResponse) Write 

func (p *StatsResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfService 

type UpfService interface {
	// Parameters:
	//  - Port
	GetStats(ctx context.Context, port int32) (_r *StatsResponse, _err error)
	// Parameters:
	//  - Port
	ClearStats(ctx context.Context, port int32) (_err error)
	// Parameters:
	//  - Port
	PcapStart(ctx context.Context, port int32) (_err error)
	// Parameters:
	//  - Port
	PcapStop(ctx context.Context, port int32) (_err error)
}

type UpfServiceClearStatsArgs 

type UpfServiceClearStatsArgs struct {
	Port int32 `thrift:"port,1,required" db:"port" json:"port"`
}

Attributes:

  • Port

func NewUpfServiceClearStatsArgs 

func NewUpfServiceClearStatsArgs() *UpfServiceClearStatsArgs

func (*UpfServiceClearStatsArgs) GetPort 

func (p *UpfServiceClearStatsArgs) GetPort() int32

func (*UpfServiceClearStatsArgs) Read 

func (p *UpfServiceClearStatsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceClearStatsArgs) ReadField1 

func (p *UpfServiceClearStatsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceClearStatsArgs) String 

func (p *UpfServiceClearStatsArgs) String() string

func (*UpfServiceClearStatsArgs) Write 

func (p *UpfServiceClearStatsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServiceClearStatsResult 

type UpfServiceClearStatsResult struct {
}

func NewUpfServiceClearStatsResult 

func NewUpfServiceClearStatsResult() *UpfServiceClearStatsResult

func (*UpfServiceClearStatsResult) Read 

func (p *UpfServiceClearStatsResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceClearStatsResult) String 

func (p *UpfServiceClearStatsResult) String() string

func (*UpfServiceClearStatsResult) Write 

func (p *UpfServiceClearStatsResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServiceClient 

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

func NewUpfServiceClient 

func NewUpfServiceClient(c thrift.TClient) *UpfServiceClient

func NewUpfServiceClientFactory 

func NewUpfServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *UpfServiceClient

func NewUpfServiceClientProtocol 

func NewUpfServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *UpfServiceClient

func (*UpfServiceClient) ClearStats 

func (p *UpfServiceClient) ClearStats(ctx context.Context, port int32) (_err error)

Parameters:

  • Port

func (*UpfServiceClient) Client_ 

func (p *UpfServiceClient) Client_() thrift.TClient

func (*UpfServiceClient) GetStats 

func (p *UpfServiceClient) GetStats(ctx context.Context, port int32) (_r *StatsResponse, _err error)

Parameters:

  • Port

func (*UpfServiceClient) LastResponseMeta_ 

func (p *UpfServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*UpfServiceClient) PcapStart 

func (p *UpfServiceClient) PcapStart(ctx context.Context, port int32) (_err error)

Parameters:

  • Port

func (*UpfServiceClient) PcapStop 

func (p *UpfServiceClient) PcapStop(ctx context.Context, port int32) (_err error)

Parameters:

  • Port

func (*UpfServiceClient) SetLastResponseMeta_ 

func (p *UpfServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type UpfServiceGetStatsArgs 

type UpfServiceGetStatsArgs struct {
	Port int32 `thrift:"port,1,required" db:"port" json:"port"`
}

Attributes:

  • Port

func NewUpfServiceGetStatsArgs 

func NewUpfServiceGetStatsArgs() *UpfServiceGetStatsArgs

func (*UpfServiceGetStatsArgs) GetPort 

func (p *UpfServiceGetStatsArgs) GetPort() int32

func (*UpfServiceGetStatsArgs) Read 

func (p *UpfServiceGetStatsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceGetStatsArgs) ReadField1 

func (p *UpfServiceGetStatsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceGetStatsArgs) String 

func (p *UpfServiceGetStatsArgs) String() string

func (*UpfServiceGetStatsArgs) Write 

func (p *UpfServiceGetStatsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServiceGetStatsResult 

type UpfServiceGetStatsResult struct {
	Success *StatsResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewUpfServiceGetStatsResult 

func NewUpfServiceGetStatsResult() *UpfServiceGetStatsResult

func (*UpfServiceGetStatsResult) GetSuccess 

func (p *UpfServiceGetStatsResult) GetSuccess() *StatsResponse

func (*UpfServiceGetStatsResult) IsSetSuccess 

func (p *UpfServiceGetStatsResult) IsSetSuccess() bool

func (*UpfServiceGetStatsResult) Read 

func (p *UpfServiceGetStatsResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceGetStatsResult) ReadField0 

func (p *UpfServiceGetStatsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServiceGetStatsResult) String 

func (p *UpfServiceGetStatsResult) String() string

func (*UpfServiceGetStatsResult) Write 

func (p *UpfServiceGetStatsResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServicePcapStartArgs 

type UpfServicePcapStartArgs struct {
	Port int32 `thrift:"port,1,required" db:"port" json:"port"`
}

Attributes:

  • Port

func NewUpfServicePcapStartArgs 

func NewUpfServicePcapStartArgs() *UpfServicePcapStartArgs

func (*UpfServicePcapStartArgs) GetPort 

func (p *UpfServicePcapStartArgs) GetPort() int32

func (*UpfServicePcapStartArgs) Read 

func (p *UpfServicePcapStartArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStartArgs) ReadField1 

func (p *UpfServicePcapStartArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStartArgs) String 

func (p *UpfServicePcapStartArgs) String() string

func (*UpfServicePcapStartArgs) Write 

func (p *UpfServicePcapStartArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServicePcapStartResult 

type UpfServicePcapStartResult struct {
}

func NewUpfServicePcapStartResult 

func NewUpfServicePcapStartResult() *UpfServicePcapStartResult

func (*UpfServicePcapStartResult) Read 

func (p *UpfServicePcapStartResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStartResult) String 

func (p *UpfServicePcapStartResult) String() string

func (*UpfServicePcapStartResult) Write 

func (p *UpfServicePcapStartResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServicePcapStopArgs 

type UpfServicePcapStopArgs struct {
	Port int32 `thrift:"port,1,required" db:"port" json:"port"`
}

Attributes:

  • Port

func NewUpfServicePcapStopArgs 

func NewUpfServicePcapStopArgs() *UpfServicePcapStopArgs

func (*UpfServicePcapStopArgs) GetPort 

func (p *UpfServicePcapStopArgs) GetPort() int32

func (*UpfServicePcapStopArgs) Read 

func (p *UpfServicePcapStopArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStopArgs) ReadField1 

func (p *UpfServicePcapStopArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStopArgs) String 

func (p *UpfServicePcapStopArgs) String() string

func (*UpfServicePcapStopArgs) Write 

func (p *UpfServicePcapStopArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServicePcapStopResult 

type UpfServicePcapStopResult struct {
}

func NewUpfServicePcapStopResult 

func NewUpfServicePcapStopResult() *UpfServicePcapStopResult

func (*UpfServicePcapStopResult) Read 

func (p *UpfServicePcapStopResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpfServicePcapStopResult) String 

func (p *UpfServicePcapStopResult) String() string

func (*UpfServicePcapStopResult) Write 

func (p *UpfServicePcapStopResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpfServiceProcessor 

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

func NewUpfServiceProcessor 

func NewUpfServiceProcessor(handler UpfService) *UpfServiceProcessor

func (*UpfServiceProcessor) AddToProcessorMap 

func (p *UpfServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*UpfServiceProcessor) GetProcessorFunction 

func (p *UpfServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*UpfServiceProcessor) Process 

func (p *UpfServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*UpfServiceProcessor) ProcessorMap 

func (p *UpfServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

Source Files

View all Source files

Directories

Path Synopsis

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.