linkqual

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2023 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	QualificationState_name = map[int32]string{
		0: "QUALIFICATION_STATE_UNSPECIFIED",
		1: "QUALIFICATION_STATE_ERROR",
		2: "QUALIFICATION_STATE_IDLE",
		3: "QUALIFICATION_STATE_SETUP",
		4: "QUALIFICATION_STATE_RUNNING",
		5: "QUALIFICATION_STATE_TEARDOWN",
		6: "QUALIFICATION_STATE_COMPLETED",
	}
	QualificationState_value = map[string]int32{
		"QUALIFICATION_STATE_UNSPECIFIED": 0,
		"QUALIFICATION_STATE_ERROR":       1,
		"QUALIFICATION_STATE_IDLE":        2,
		"QUALIFICATION_STATE_SETUP":       3,
		"QUALIFICATION_STATE_RUNNING":     4,
		"QUALIFICATION_STATE_TEARDOWN":    5,
		"QUALIFICATION_STATE_COMPLETED":   6,
	}
)

Enum value maps for QualificationState.

View Source
var (
	PacketInjectorLoopbackMode_name = map[int32]string{
		0: "PACKET_INJECTOR_LOOPBACK_MODE_UNSPECIFIED",
		1: "PACKET_INJECTOR_LOOPBACK_MODE_PMD",
		2: "PACKET_INJECTOR_LOOPBACK_MODE_ASIC",
	}
	PacketInjectorLoopbackMode_value = map[string]int32{
		"PACKET_INJECTOR_LOOPBACK_MODE_UNSPECIFIED": 0,
		"PACKET_INJECTOR_LOOPBACK_MODE_PMD":         1,
		"PACKET_INJECTOR_LOOPBACK_MODE_ASIC":        2,
	}
)

Enum value maps for PacketInjectorLoopbackMode.

View Source
var (
	HeaderMatchField_name = map[int32]string{
		0: "HEADER_MATCH_FIELD_UNSPECIFIED",
		1: "HEADER_MATCH_FIELD_L2",
		2: "HEADER_MATCH_FIELD_L3",
		3: "HEADER_MATCH_FIELD_L4",
	}
	HeaderMatchField_value = map[string]int32{
		"HEADER_MATCH_FIELD_UNSPECIFIED": 0,
		"HEADER_MATCH_FIELD_L2":          1,
		"HEADER_MATCH_FIELD_L3":          2,
		"HEADER_MATCH_FIELD_L4":          3,
	}
)

Enum value maps for HeaderMatchField.

View Source
var File_packet_link_qualification_packet_link_qualification_proto protoreflect.FileDescriptor
View Source
var LinkQualification_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gnoi.packet_link_qualification.LinkQualification",
	HandlerType: (*LinkQualificationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _LinkQualification_Create_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _LinkQualification_Get_Handler,
		},
		{
			MethodName: "Capabilities",
			Handler:    _LinkQualification_Capabilities_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _LinkQualification_Delete_Handler,
		},
		{
			MethodName: "List",
			Handler:    _LinkQualification_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packet_link_qualification/packet_link_qualification.proto",
}

LinkQualification_ServiceDesc is the grpc.ServiceDesc for LinkQualification service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLinkQualificationServer

func RegisterLinkQualificationServer(s grpc.ServiceRegistrar, srv LinkQualificationServer)

Types

type AsicLoopbackCapabilities

type AsicLoopbackCapabilities struct {

	// The minimum time required to set up the ASIC loopback mode.
	MinSetupDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=min_setup_duration,json=minSetupDuration,proto3" json:"min_setup_duration,omitempty"`
	// The minimum time required to return the interfaces to their pre-test state
	// following a qualification.
	MinTeardownDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=min_teardown_duration,json=minTeardownDuration,proto3" json:"min_teardown_duration,omitempty"`
	Fields              []HeaderMatchField   `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AsicLoopbackCapabilities) Descriptor deprecated

func (*AsicLoopbackCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use AsicLoopbackCapabilities.ProtoReflect.Descriptor instead.

func (*AsicLoopbackCapabilities) GetFields

func (x *AsicLoopbackCapabilities) GetFields() []HeaderMatchField

func (*AsicLoopbackCapabilities) GetMinSetupDuration

func (x *AsicLoopbackCapabilities) GetMinSetupDuration() *durationpb.Duration

func (*AsicLoopbackCapabilities) GetMinTeardownDuration

func (x *AsicLoopbackCapabilities) GetMinTeardownDuration() *durationpb.Duration

func (*AsicLoopbackCapabilities) ProtoMessage

func (*AsicLoopbackCapabilities) ProtoMessage()

func (*AsicLoopbackCapabilities) ProtoReflect

func (x *AsicLoopbackCapabilities) ProtoReflect() protoreflect.Message

func (*AsicLoopbackCapabilities) Reset

func (x *AsicLoopbackCapabilities) Reset()

func (*AsicLoopbackCapabilities) String

func (x *AsicLoopbackCapabilities) String() string

type AsicLoopbackConfiguration

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

func (*AsicLoopbackConfiguration) Descriptor deprecated

func (*AsicLoopbackConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use AsicLoopbackConfiguration.ProtoReflect.Descriptor instead.

func (*AsicLoopbackConfiguration) ProtoMessage

func (*AsicLoopbackConfiguration) ProtoMessage()

func (*AsicLoopbackConfiguration) ProtoReflect

func (*AsicLoopbackConfiguration) Reset

func (x *AsicLoopbackConfiguration) Reset()

func (*AsicLoopbackConfiguration) String

func (x *AsicLoopbackConfiguration) String() string

type CapabilitiesRequest

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

func (*CapabilitiesRequest) Descriptor deprecated

func (*CapabilitiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use CapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*CapabilitiesRequest) ProtoMessage

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) ProtoReflect

func (x *CapabilitiesRequest) ProtoReflect() protoreflect.Message

func (*CapabilitiesRequest) Reset

func (x *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) String

func (x *CapabilitiesRequest) String() string

type CapabilitiesResponse

type CapabilitiesResponse struct {

	// Current timestamp on the service.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Indicates that the device's time is currently synchronised via NTP.
	NtpSynced bool `protobuf:"varint,2,opt,name=ntp_synced,json=ntpSynced,proto3" json:"ntp_synced,omitempty"`
	// Capabilities that the generator and reflect support on the
	// service. If the top level field is unset the service cannot act
	// as any defined generator or reflector.
	Generator *GeneratorCapabilities `protobuf:"bytes,3,opt,name=generator,proto3" json:"generator,omitempty"`
	Reflector *ReflectorCapabilities `protobuf:"bytes,4,opt,name=reflector,proto3" json:"reflector,omitempty"`
	// Maximum number of results allowed to be stored per interface.
	// The minimum supported just be 2 or greater.
	MaxHistoricalResultsPerInterface uint64 `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CapabilitiesResponse) Descriptor deprecated

func (*CapabilitiesResponse) Descriptor() ([]byte, []int)

Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*CapabilitiesResponse) GetGenerator

func (x *CapabilitiesResponse) GetGenerator() *GeneratorCapabilities

func (*CapabilitiesResponse) GetMaxHistoricalResultsPerInterface

func (x *CapabilitiesResponse) GetMaxHistoricalResultsPerInterface() uint64

func (*CapabilitiesResponse) GetNtpSynced

func (x *CapabilitiesResponse) GetNtpSynced() bool

func (*CapabilitiesResponse) GetReflector

func (x *CapabilitiesResponse) GetReflector() *ReflectorCapabilities

func (*CapabilitiesResponse) GetTime

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) ProtoReflect

func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message

func (*CapabilitiesResponse) Reset

func (x *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) String

func (x *CapabilitiesResponse) String() string

type CreateRequest

type CreateRequest struct {
	Interfaces []*QualificationConfiguration `protobuf:"bytes,1,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
	// contains filtered or unexported fields
}

CreateRequest contains the list of interfaces to be Qualified. Each interface must only appear once and all IDs to be used by qualification must be unique on the device.

func (*CreateRequest) Descriptor deprecated

func (*CreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetInterfaces

func (x *CreateRequest) GetInterfaces() []*QualificationConfiguration

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset

func (x *CreateRequest) Reset()

func (*CreateRequest) String

func (x *CreateRequest) String() string

type CreateResponse

type CreateResponse struct {
	Status map[string]*status.Status `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

CreateResponse will return a map of the status of each CreateRequest. The map key is the qualification id requested in the CreateRequest. Valid Status responses are: OK: create has been accepted. NOT_FOUND: interface_name could not be found on the service. INVALID_ARGUMENT: if any of the configuration is not supported. ALREADY_EXISTS: if the qualification id is already in use.

func (*CreateResponse) Descriptor deprecated

func (*CreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetStatus

func (x *CreateResponse) GetStatus() map[string]*status.Status

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset

func (x *CreateResponse) Reset()

func (*CreateResponse) String

func (x *CreateResponse) String() string

type DeleteRequest

type DeleteRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

DeleteRequest will delete the qualification results for the provided id.

func (*DeleteRequest) Descriptor deprecated

func (*DeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetIds

func (x *DeleteRequest) GetIds() []string

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type DeleteResponse

type DeleteResponse struct {
	Results map[string]*status.Status `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Delete response will contain a list of all id's in the request to be deleted. If the id was not found NOT_FOUND will be returned.

func (*DeleteResponse) Descriptor deprecated

func (*DeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetResults

func (x *DeleteResponse) GetResults() map[string]*status.Status

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

type GeneratorCapabilities

type GeneratorCapabilities struct {
	PacketGenerator *PacketGeneratorCapabilities `protobuf:"bytes,1,opt,name=packet_generator,json=packetGenerator,proto3" json:"packet_generator,omitempty"`
	PacketInjector  *PacketInjectorCapabilities  `protobuf:"bytes,2,opt,name=packet_injector,json=packetInjector,proto3" json:"packet_injector,omitempty"`
	// contains filtered or unexported fields
}

If the service does not support any of the defined modes then the message should be unset.

func (*GeneratorCapabilities) Descriptor deprecated

func (*GeneratorCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use GeneratorCapabilities.ProtoReflect.Descriptor instead.

func (*GeneratorCapabilities) GetPacketGenerator

func (x *GeneratorCapabilities) GetPacketGenerator() *PacketGeneratorCapabilities

func (*GeneratorCapabilities) GetPacketInjector

func (x *GeneratorCapabilities) GetPacketInjector() *PacketInjectorCapabilities

func (*GeneratorCapabilities) ProtoMessage

func (*GeneratorCapabilities) ProtoMessage()

func (*GeneratorCapabilities) ProtoReflect

func (x *GeneratorCapabilities) ProtoReflect() protoreflect.Message

func (*GeneratorCapabilities) Reset

func (x *GeneratorCapabilities) Reset()

func (*GeneratorCapabilities) String

func (x *GeneratorCapabilities) String() string

type GetRequest

type GetRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

GetRequest returns the status for the provided ids.

func (*GetRequest) Descriptor deprecated

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetIds

func (x *GetRequest) GetIds() []string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Results map[string]*QualificationResult `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetResponse returns a map containing the values for all requested Qualification results. If the QualificationResult state is QUALIFICATION_STATE_ERROR the caller should inspect the status field for the exact error code and message. Expected errors codes: NOT_FOUND when the requested id was not found by the service. INVALID_ARGUMENT for any configuration parameter which is unsupported.

func (*GetResponse) Descriptor deprecated

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetResults

func (x *GetResponse) GetResults() map[string]*QualificationResult

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type HeaderMatchField

type HeaderMatchField int32
const (
	HeaderMatchField_HEADER_MATCH_FIELD_UNSPECIFIED HeaderMatchField = 0
	HeaderMatchField_HEADER_MATCH_FIELD_L2          HeaderMatchField = 1
	HeaderMatchField_HEADER_MATCH_FIELD_L3          HeaderMatchField = 2
	HeaderMatchField_HEADER_MATCH_FIELD_L4          HeaderMatchField = 3
)

func (HeaderMatchField) Descriptor

func (HeaderMatchField) Enum

func (HeaderMatchField) EnumDescriptor deprecated

func (HeaderMatchField) EnumDescriptor() ([]byte, []int)

Deprecated: Use HeaderMatchField.Descriptor instead.

func (HeaderMatchField) Number

func (HeaderMatchField) String

func (x HeaderMatchField) String() string

func (HeaderMatchField) Type

type LinkQualificationClient

type LinkQualificationClient interface {
	// Create will dispatch a create operation for each interface and return.
	// The rpc will only return an error in the case that gNOI service cannot
	// handle the RPC request. Create will return an error on failure to
	// create the qualification.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Get will return the status for the provided qualification ids.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Capabilities will return the capabilities of the gnoi.LinkQualification
	// service implementation.  This RPC is used to allow the caller to
	// orchestrate the peer requirements of the service to complete a link
	// qualification between two devices.
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
	// Delete will remove the qualification results for the provided ids.
	// If the qualification is not in QUALIFICATION_STATE_COMPLETED
	// or QUALIFICATION_STATE_ERROR, the qualification will be canceled then
	// deleted as requested.
	// If the qualification cannot be stopped or deleted a status will be returned
	// with the error.
	// If the id is not found NOT_FOUND will be returned.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// List qualifications currently on the target.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
}

LinkQualificationClient is the client API for LinkQualification service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LinkQualificationServer

type LinkQualificationServer interface {
	// Create will dispatch a create operation for each interface and return.
	// The rpc will only return an error in the case that gNOI service cannot
	// handle the RPC request. Create will return an error on failure to
	// create the qualification.
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Get will return the status for the provided qualification ids.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Capabilities will return the capabilities of the gnoi.LinkQualification
	// service implementation.  This RPC is used to allow the caller to
	// orchestrate the peer requirements of the service to complete a link
	// qualification between two devices.
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
	// Delete will remove the qualification results for the provided ids.
	// If the qualification is not in QUALIFICATION_STATE_COMPLETED
	// or QUALIFICATION_STATE_ERROR, the qualification will be canceled then
	// deleted as requested.
	// If the qualification cannot be stopped or deleted a status will be returned
	// with the error.
	// If the id is not found NOT_FOUND will be returned.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// List qualifications currently on the target.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// contains filtered or unexported methods
}

LinkQualificationServer is the server API for LinkQualification service. All implementations must embed UnimplementedLinkQualificationServer for forward compatibility

type ListRequest

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

func (*ListRequest) Descriptor deprecated

func (*ListRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type ListResponse

type ListResponse struct {

	// The results that have not yet been deleted from the device.
	Results []*ListResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated

func (*ListResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetResults

func (x *ListResponse) GetResults() []*ListResult

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset

func (x *ListResponse) Reset()

func (*ListResponse) String

func (x *ListResponse) String() string

type ListResult

type ListResult struct {
	Id            string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State         QualificationState `protobuf:"varint,2,opt,name=state,proto3,enum=gnoi.packet_link_qualification.QualificationState" json:"state,omitempty"`
	InterfaceName string             `protobuf:"bytes,3,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResult) Descriptor deprecated

func (*ListResult) Descriptor() ([]byte, []int)

Deprecated: Use ListResult.ProtoReflect.Descriptor instead.

func (*ListResult) GetId

func (x *ListResult) GetId() string

func (*ListResult) GetInterfaceName

func (x *ListResult) GetInterfaceName() string

func (*ListResult) GetState

func (x *ListResult) GetState() QualificationState

func (*ListResult) ProtoMessage

func (*ListResult) ProtoMessage()

func (*ListResult) ProtoReflect

func (x *ListResult) ProtoReflect() protoreflect.Message

func (*ListResult) Reset

func (x *ListResult) Reset()

func (*ListResult) String

func (x *ListResult) String() string

type NTPSyncedTiming

type NTPSyncedTiming struct {

	// The timestamp for the start of the qualification. Based on the
	// provided configuration the qualification setup must
	// at least start at (start_time - min_setup_time).
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The timestamp for the end of qualification.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Timestamp to begin teardown. If unset teardown will start
	// immediately after end_time.
	// This value allows for a peer to wait for before tearing down
	// the port under test.
	// teardown_time must occur after end_time.
	TeardownTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=teardown_time,json=teardownTime,proto3" json:"teardown_time,omitempty"`
	// contains filtered or unexported fields
}

func (*NTPSyncedTiming) Descriptor deprecated

func (*NTPSyncedTiming) Descriptor() ([]byte, []int)

Deprecated: Use NTPSyncedTiming.ProtoReflect.Descriptor instead.

func (*NTPSyncedTiming) GetEndTime

func (x *NTPSyncedTiming) GetEndTime() *timestamppb.Timestamp

func (*NTPSyncedTiming) GetStartTime

func (x *NTPSyncedTiming) GetStartTime() *timestamppb.Timestamp

func (*NTPSyncedTiming) GetTeardownTime

func (x *NTPSyncedTiming) GetTeardownTime() *timestamppb.Timestamp

func (*NTPSyncedTiming) ProtoMessage

func (*NTPSyncedTiming) ProtoMessage()

func (*NTPSyncedTiming) ProtoReflect

func (x *NTPSyncedTiming) ProtoReflect() protoreflect.Message

func (*NTPSyncedTiming) Reset

func (x *NTPSyncedTiming) Reset()

func (*NTPSyncedTiming) String

func (x *NTPSyncedTiming) String() string

type PacketGeneratorCapabilities

type PacketGeneratorCapabilities struct {
	MaxBps uint64 `protobuf:"varint,1,opt,name=max_bps,json=maxBps,proto3" json:"max_bps,omitempty"` // bits per second
	MaxPps uint64 `protobuf:"varint,2,opt,name=max_pps,json=maxPps,proto3" json:"max_pps,omitempty"` // packets per second
	MinMtu uint32 `protobuf:"varint,3,opt,name=min_mtu,json=minMtu,proto3" json:"min_mtu,omitempty"` // minimum MTU supported.
	MaxMtu uint32 `protobuf:"varint,4,opt,name=max_mtu,json=maxMtu,proto3" json:"max_mtu,omitempty"` // max MTU supported.
	// The minimum duration required to set up a packet generator-based
	// qualification.
	MinSetupDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=min_setup_duration,json=minSetupDuration,proto3" json:"min_setup_duration,omitempty"`
	// The minimum time required to return the affected interface to the
	// pre-test state.
	MinTeardownDuration *durationpb.Duration `protobuf:"bytes,6,opt,name=min_teardown_duration,json=minTeardownDuration,proto3" json:"min_teardown_duration,omitempty"`
	// The minimum interval between samples for statistics relating to the
	// qualification.
	MinSampleInterval *durationpb.Duration `protobuf:"bytes,7,opt,name=min_sample_interval,json=minSampleInterval,proto3" json:"min_sample_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketGeneratorCapabilities) Descriptor deprecated

func (*PacketGeneratorCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use PacketGeneratorCapabilities.ProtoReflect.Descriptor instead.

func (*PacketGeneratorCapabilities) GetMaxBps

func (x *PacketGeneratorCapabilities) GetMaxBps() uint64

func (*PacketGeneratorCapabilities) GetMaxMtu

func (x *PacketGeneratorCapabilities) GetMaxMtu() uint32

func (*PacketGeneratorCapabilities) GetMaxPps

func (x *PacketGeneratorCapabilities) GetMaxPps() uint64

func (*PacketGeneratorCapabilities) GetMinMtu

func (x *PacketGeneratorCapabilities) GetMinMtu() uint32

func (*PacketGeneratorCapabilities) GetMinSampleInterval

func (x *PacketGeneratorCapabilities) GetMinSampleInterval() *durationpb.Duration

func (*PacketGeneratorCapabilities) GetMinSetupDuration

func (x *PacketGeneratorCapabilities) GetMinSetupDuration() *durationpb.Duration

func (*PacketGeneratorCapabilities) GetMinTeardownDuration

func (x *PacketGeneratorCapabilities) GetMinTeardownDuration() *durationpb.Duration

func (*PacketGeneratorCapabilities) ProtoMessage

func (*PacketGeneratorCapabilities) ProtoMessage()

func (*PacketGeneratorCapabilities) ProtoReflect

func (*PacketGeneratorCapabilities) Reset

func (x *PacketGeneratorCapabilities) Reset()

func (*PacketGeneratorCapabilities) String

func (x *PacketGeneratorCapabilities) String() string

type PacketGeneratorConfiguration

type PacketGeneratorConfiguration struct {

	// Packet per second rate to use for this test.
	PacketRate uint64 `protobuf:"varint,1,opt,name=packet_rate,json=packetRate,proto3" json:"packet_rate,omitempty"`
	// Size of packets to inject.
	// if unspecified, the default value is 1500 bytes.
	PacketSize uint32 `protobuf:"varint,2,opt,name=packet_size,json=packetSize,proto3" json:"packet_size,omitempty"`
	// contains filtered or unexported fields
}

A packet generator implementation defines that the generator of the side of the link will be responsible for generating a stream of packets at the provided rate and size.

func (*PacketGeneratorConfiguration) Descriptor deprecated

func (*PacketGeneratorConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use PacketGeneratorConfiguration.ProtoReflect.Descriptor instead.

func (*PacketGeneratorConfiguration) GetPacketRate

func (x *PacketGeneratorConfiguration) GetPacketRate() uint64

func (*PacketGeneratorConfiguration) GetPacketSize

func (x *PacketGeneratorConfiguration) GetPacketSize() uint32

func (*PacketGeneratorConfiguration) ProtoMessage

func (*PacketGeneratorConfiguration) ProtoMessage()

func (*PacketGeneratorConfiguration) ProtoReflect

func (*PacketGeneratorConfiguration) Reset

func (x *PacketGeneratorConfiguration) Reset()

func (*PacketGeneratorConfiguration) String

type PacketInjectorCapabilities

type PacketInjectorCapabilities struct {

	// The definitions of fields 1-7 are the same as those described in the
	// PacketGeneratorCapabilities message.
	MinMtu              uint32               `protobuf:"varint,1,opt,name=min_mtu,json=minMtu,proto3" json:"min_mtu,omitempty"`
	MaxMtu              uint32               `protobuf:"varint,2,opt,name=max_mtu,json=maxMtu,proto3" json:"max_mtu,omitempty"`
	MinInjectedPackets  uint32               `protobuf:"varint,3,opt,name=min_injected_packets,json=minInjectedPackets,proto3" json:"min_injected_packets,omitempty"`
	MaxInjectedPackets  uint32               `protobuf:"varint,4,opt,name=max_injected_packets,json=maxInjectedPackets,proto3" json:"max_injected_packets,omitempty"`
	MinSetupDuration    *durationpb.Duration `protobuf:"bytes,5,opt,name=min_setup_duration,json=minSetupDuration,proto3" json:"min_setup_duration,omitempty"`
	MinTeardownDuration *durationpb.Duration `protobuf:"bytes,6,opt,name=min_teardown_duration,json=minTeardownDuration,proto3" json:"min_teardown_duration,omitempty"`
	MinSampleInterval   *durationpb.Duration `protobuf:"bytes,7,opt,name=min_sample_interval,json=minSampleInterval,proto3" json:"min_sample_interval,omitempty"`
	// Loopback modes that are supported by the device when using the packet
	// injector mode.
	LoopbackModes []PacketInjectorLoopbackMode `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PacketInjectorCapabilities) Descriptor deprecated

func (*PacketInjectorCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use PacketInjectorCapabilities.ProtoReflect.Descriptor instead.

func (*PacketInjectorCapabilities) GetLoopbackModes

func (*PacketInjectorCapabilities) GetMaxInjectedPackets

func (x *PacketInjectorCapabilities) GetMaxInjectedPackets() uint32

func (*PacketInjectorCapabilities) GetMaxMtu

func (x *PacketInjectorCapabilities) GetMaxMtu() uint32

func (*PacketInjectorCapabilities) GetMinInjectedPackets

func (x *PacketInjectorCapabilities) GetMinInjectedPackets() uint32

func (*PacketInjectorCapabilities) GetMinMtu

func (x *PacketInjectorCapabilities) GetMinMtu() uint32

func (*PacketInjectorCapabilities) GetMinSampleInterval

func (x *PacketInjectorCapabilities) GetMinSampleInterval() *durationpb.Duration

func (*PacketInjectorCapabilities) GetMinSetupDuration

func (x *PacketInjectorCapabilities) GetMinSetupDuration() *durationpb.Duration

func (*PacketInjectorCapabilities) GetMinTeardownDuration

func (x *PacketInjectorCapabilities) GetMinTeardownDuration() *durationpb.Duration

func (*PacketInjectorCapabilities) ProtoMessage

func (*PacketInjectorCapabilities) ProtoMessage()

func (*PacketInjectorCapabilities) ProtoReflect

func (*PacketInjectorCapabilities) Reset

func (x *PacketInjectorCapabilities) Reset()

func (*PacketInjectorCapabilities) String

func (x *PacketInjectorCapabilities) String() string

type PacketInjectorConfiguration

type PacketInjectorConfiguration struct {

	// Number of packets to inject into the closed loop.
	PacketCount uint32 `protobuf:"varint,1,opt,name=packet_count,json=packetCount,proto3" json:"packet_count,omitempty"`
	// Size of packets to inject.
	// if unspecified, the default value is 1500 bytes.
	PacketSize uint32 `protobuf:"varint,2,opt,name=packet_size,json=packetSize,proto3" json:"packet_size,omitempty"`
	// Loopback mode for this qualification.
	//
	// Types that are assignable to LoopbackMode:
	//
	//	*PacketInjectorConfiguration_PmdLoopback
	//	*PacketInjectorConfiguration_AsicLoopback
	LoopbackMode isPacketInjectorConfiguration_LoopbackMode `protobuf_oneof:"loopback_mode"`
	// contains filtered or unexported fields
}

A packet injector implementation defines that the generator side of the link will be responsible for both setting the interface into a loopback as well as injecting individual packets up to packet_count into the closed loop at the packet_size. These packets will form a closed loop as both sides of the loop will forward the same set of packets for the duration of the qualification.

func (*PacketInjectorConfiguration) Descriptor deprecated

func (*PacketInjectorConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use PacketInjectorConfiguration.ProtoReflect.Descriptor instead.

func (*PacketInjectorConfiguration) GetAsicLoopback

func (*PacketInjectorConfiguration) GetLoopbackMode

func (m *PacketInjectorConfiguration) GetLoopbackMode() isPacketInjectorConfiguration_LoopbackMode

func (*PacketInjectorConfiguration) GetPacketCount

func (x *PacketInjectorConfiguration) GetPacketCount() uint32

func (*PacketInjectorConfiguration) GetPacketSize

func (x *PacketInjectorConfiguration) GetPacketSize() uint32

func (*PacketInjectorConfiguration) GetPmdLoopback

func (*PacketInjectorConfiguration) ProtoMessage

func (*PacketInjectorConfiguration) ProtoMessage()

func (*PacketInjectorConfiguration) ProtoReflect

func (*PacketInjectorConfiguration) Reset

func (x *PacketInjectorConfiguration) Reset()

func (*PacketInjectorConfiguration) String

func (x *PacketInjectorConfiguration) String() string

type PacketInjectorConfiguration_AsicLoopback

type PacketInjectorConfiguration_AsicLoopback struct {
	// ASIC based loops are done inside the forwarding
	// engine and must have stats available to the
	// qualification.
	AsicLoopback *AsicLoopbackConfiguration `protobuf:"bytes,102,opt,name=asic_loopback,json=asicLoopback,proto3,oneof"`
}

type PacketInjectorConfiguration_PmdLoopback

type PacketInjectorConfiguration_PmdLoopback struct {
	// PMD based loopback encompasses either PHY based port
	// loopbacks or port based ASIC loopbacks which do
	// use forwarding engine processing.
	// Their use may limit the stats available for the
	// qualification.
	PmdLoopback *PmdLoopbackConfiguration `protobuf:"bytes,101,opt,name=pmd_loopback,json=pmdLoopback,proto3,oneof"`
}

type PacketInjectorLoopbackMode

type PacketInjectorLoopbackMode int32
const (
	PacketInjectorLoopbackMode_PACKET_INJECTOR_LOOPBACK_MODE_UNSPECIFIED PacketInjectorLoopbackMode = 0
	PacketInjectorLoopbackMode_PACKET_INJECTOR_LOOPBACK_MODE_PMD         PacketInjectorLoopbackMode = 1
	PacketInjectorLoopbackMode_PACKET_INJECTOR_LOOPBACK_MODE_ASIC        PacketInjectorLoopbackMode = 2
)

func (PacketInjectorLoopbackMode) Descriptor

func (PacketInjectorLoopbackMode) Enum

func (PacketInjectorLoopbackMode) EnumDescriptor deprecated

func (PacketInjectorLoopbackMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use PacketInjectorLoopbackMode.Descriptor instead.

func (PacketInjectorLoopbackMode) Number

func (PacketInjectorLoopbackMode) String

func (PacketInjectorLoopbackMode) Type

type PmdLoopbackCapabilities

type PmdLoopbackCapabilities struct {
	MinSetupDuration    *durationpb.Duration `protobuf:"bytes,1,opt,name=min_setup_duration,json=minSetupDuration,proto3" json:"min_setup_duration,omitempty"`
	MinTeardownDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=min_teardown_duration,json=minTeardownDuration,proto3" json:"min_teardown_duration,omitempty"`
	// contains filtered or unexported fields
}

PMD or port based loopbacks are expect to have limited ability to report packet counters. Packet rate/errors/transmitted/received may not be available on the remote side for these types of loopbacks.

func (*PmdLoopbackCapabilities) Descriptor deprecated

func (*PmdLoopbackCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use PmdLoopbackCapabilities.ProtoReflect.Descriptor instead.

func (*PmdLoopbackCapabilities) GetMinSetupDuration

func (x *PmdLoopbackCapabilities) GetMinSetupDuration() *durationpb.Duration

func (*PmdLoopbackCapabilities) GetMinTeardownDuration

func (x *PmdLoopbackCapabilities) GetMinTeardownDuration() *durationpb.Duration

func (*PmdLoopbackCapabilities) ProtoMessage

func (*PmdLoopbackCapabilities) ProtoMessage()

func (*PmdLoopbackCapabilities) ProtoReflect

func (x *PmdLoopbackCapabilities) ProtoReflect() protoreflect.Message

func (*PmdLoopbackCapabilities) Reset

func (x *PmdLoopbackCapabilities) Reset()

func (*PmdLoopbackCapabilities) String

func (x *PmdLoopbackCapabilities) String() string

type PmdLoopbackConfiguration

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

func (*PmdLoopbackConfiguration) Descriptor deprecated

func (*PmdLoopbackConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use PmdLoopbackConfiguration.ProtoReflect.Descriptor instead.

func (*PmdLoopbackConfiguration) ProtoMessage

func (*PmdLoopbackConfiguration) ProtoMessage()

func (*PmdLoopbackConfiguration) ProtoReflect

func (x *PmdLoopbackConfiguration) ProtoReflect() protoreflect.Message

func (*PmdLoopbackConfiguration) Reset

func (x *PmdLoopbackConfiguration) Reset()

func (*PmdLoopbackConfiguration) String

func (x *PmdLoopbackConfiguration) String() string

type QualificationConfiguration

type QualificationConfiguration struct {

	// Id to be used for this interface qualification run.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// interface name on the device must be unique to the device.
	InterfaceName string `protobuf:"bytes,2,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	// timing allows for specifying either NTP or by using the Create RPC as
	// the synchronization method for the qualification.
	//
	// Types that are assignable to Timing:
	//
	//	*QualificationConfiguration_Ntp
	//	*QualificationConfiguration_Rpc
	Timing isQualificationConfiguration_Timing `protobuf_oneof:"timing"`
	// endpoint_type is how this side of the link will be configured for the
	// qualification.
	//
	// Types that are assignable to EndpointType:
	//
	//	*QualificationConfiguration_PacketGenerator
	//	*QualificationConfiguration_PacketInjector
	//	*QualificationConfiguration_PmdLoopback
	//	*QualificationConfiguration_AsicLoopback
	EndpointType isQualificationConfiguration_EndpointType `protobuf_oneof:"endpoint_type"`
	// contains filtered or unexported fields
}

func (*QualificationConfiguration) Descriptor deprecated

func (*QualificationConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use QualificationConfiguration.ProtoReflect.Descriptor instead.

func (*QualificationConfiguration) GetAsicLoopback

func (*QualificationConfiguration) GetEndpointType

func (m *QualificationConfiguration) GetEndpointType() isQualificationConfiguration_EndpointType

func (*QualificationConfiguration) GetId

func (*QualificationConfiguration) GetInterfaceName

func (x *QualificationConfiguration) GetInterfaceName() string

func (*QualificationConfiguration) GetNtp

func (*QualificationConfiguration) GetPacketGenerator

func (*QualificationConfiguration) GetPacketInjector

func (*QualificationConfiguration) GetPmdLoopback

func (*QualificationConfiguration) GetRpc

func (*QualificationConfiguration) GetTiming

func (m *QualificationConfiguration) GetTiming() isQualificationConfiguration_Timing

func (*QualificationConfiguration) ProtoMessage

func (*QualificationConfiguration) ProtoMessage()

func (*QualificationConfiguration) ProtoReflect

func (*QualificationConfiguration) Reset

func (x *QualificationConfiguration) Reset()

func (*QualificationConfiguration) String

func (x *QualificationConfiguration) String() string

type QualificationConfiguration_AsicLoopback

type QualificationConfiguration_AsicLoopback struct {
	AsicLoopback *AsicLoopbackConfiguration `protobuf:"bytes,114,opt,name=asic_loopback,json=asicLoopback,proto3,oneof"`
}

type QualificationConfiguration_Ntp

type QualificationConfiguration_Ntp struct {
	Ntp *NTPSyncedTiming `protobuf:"bytes,101,opt,name=ntp,proto3,oneof"`
}

type QualificationConfiguration_PacketGenerator

type QualificationConfiguration_PacketGenerator struct {
	PacketGenerator *PacketGeneratorConfiguration `protobuf:"bytes,111,opt,name=packet_generator,json=packetGenerator,proto3,oneof"`
}

type QualificationConfiguration_PacketInjector

type QualificationConfiguration_PacketInjector struct {
	PacketInjector *PacketInjectorConfiguration `protobuf:"bytes,112,opt,name=packet_injector,json=packetInjector,proto3,oneof"`
}

type QualificationConfiguration_PmdLoopback

type QualificationConfiguration_PmdLoopback struct {
	PmdLoopback *PmdLoopbackConfiguration `protobuf:"bytes,113,opt,name=pmd_loopback,json=pmdLoopback,proto3,oneof"`
}

type QualificationConfiguration_Rpc

type QualificationConfiguration_Rpc struct {
	Rpc *RPCSyncedTiming `protobuf:"bytes,102,opt,name=rpc,proto3,oneof"`
}

type QualificationResult

type QualificationResult struct {

	// ID of the qualification.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Interface name of the qualification.
	InterfaceName string `protobuf:"bytes,2,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	// The state the test was in when the results were snapshotted.
	State QualificationState `protobuf:"varint,3,opt,name=state,proto3,enum=gnoi.packet_link_qualification.QualificationState" json:"state,omitempty"`
	// The number of qualification packets sent.
	PacketsSent uint64 `protobuf:"varint,4,opt,name=packets_sent,json=packetsSent,proto3" json:"packets_sent,omitempty"`
	// The number of qualification packets received.
	PacketsReceived uint64 `protobuf:"varint,5,opt,name=packets_received,json=packetsReceived,proto3" json:"packets_received,omitempty"`
	// The number of packets transmitted that experienced corruption.
	PacketsError uint64 `protobuf:"varint,6,opt,name=packets_error,json=packetsError,proto3" json:"packets_error,omitempty"`
	// The number of packets dropped by the device due to internal drop,
	// lookup or forwarding errors.
	PacketsDropped uint64 `protobuf:"varint,7,opt,name=packets_dropped,json=packetsDropped,proto3" json:"packets_dropped,omitempty"`
	// The qualification start time. Also when the first snapshot of
	// results are taken.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The qualification end time or the current snapshot time since epoch.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Expected rate for the qualification. This is the computed or
	// observed rate that the service expected to be maintained
	// throughout the qualification duration.
	ExpectedRateBytesPerSecond uint64 `` /* 147-byte string literal not displayed */
	// The qualification rate observed during the qualification.
	// It is updated every min_sample_interval in bytes per second.
	QualificationRateBytesPerSecond uint64 `` /* 162-byte string literal not displayed */
	// Status response for the Qualification result. Will only be set if the
	// state is QUALIFICATION_STATE_ERROR.
	Status *status.Status `protobuf:"bytes,12,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*QualificationResult) Descriptor deprecated

func (*QualificationResult) Descriptor() ([]byte, []int)

Deprecated: Use QualificationResult.ProtoReflect.Descriptor instead.

func (*QualificationResult) GetEndTime

func (x *QualificationResult) GetEndTime() *timestamppb.Timestamp

func (*QualificationResult) GetExpectedRateBytesPerSecond

func (x *QualificationResult) GetExpectedRateBytesPerSecond() uint64

func (*QualificationResult) GetId

func (x *QualificationResult) GetId() string

func (*QualificationResult) GetInterfaceName

func (x *QualificationResult) GetInterfaceName() string

func (*QualificationResult) GetPacketsDropped

func (x *QualificationResult) GetPacketsDropped() uint64

func (*QualificationResult) GetPacketsError

func (x *QualificationResult) GetPacketsError() uint64

func (*QualificationResult) GetPacketsReceived

func (x *QualificationResult) GetPacketsReceived() uint64

func (*QualificationResult) GetPacketsSent

func (x *QualificationResult) GetPacketsSent() uint64

func (*QualificationResult) GetQualificationRateBytesPerSecond

func (x *QualificationResult) GetQualificationRateBytesPerSecond() uint64

func (*QualificationResult) GetStartTime

func (x *QualificationResult) GetStartTime() *timestamppb.Timestamp

func (*QualificationResult) GetState

func (*QualificationResult) GetStatus

func (x *QualificationResult) GetStatus() *status.Status

func (*QualificationResult) ProtoMessage

func (*QualificationResult) ProtoMessage()

func (*QualificationResult) ProtoReflect

func (x *QualificationResult) ProtoReflect() protoreflect.Message

func (*QualificationResult) Reset

func (x *QualificationResult) Reset()

func (*QualificationResult) String

func (x *QualificationResult) String() string

type QualificationState

type QualificationState int32

States of qualification.

const (
	QualificationState_QUALIFICATION_STATE_UNSPECIFIED QualificationState = 0
	QualificationState_QUALIFICATION_STATE_ERROR       QualificationState = 1 // The qualification has errored.
	QualificationState_QUALIFICATION_STATE_IDLE        QualificationState = 2 // Initial state for the qualification.
	QualificationState_QUALIFICATION_STATE_SETUP       QualificationState = 3 // Interface is being configured.
	QualificationState_QUALIFICATION_STATE_RUNNING     QualificationState = 4 // Qualification underway.
	QualificationState_QUALIFICATION_STATE_TEARDOWN    QualificationState = 5 // Interface is being reset.
	QualificationState_QUALIFICATION_STATE_COMPLETED   QualificationState = 6 // Qualification is complete.
)

func (QualificationState) Descriptor

func (QualificationState) Enum

func (QualificationState) EnumDescriptor deprecated

func (QualificationState) EnumDescriptor() ([]byte, []int)

Deprecated: Use QualificationState.Descriptor instead.

func (QualificationState) Number

func (QualificationState) String

func (x QualificationState) String() string

func (QualificationState) Type

type RPCSyncedTiming

type RPCSyncedTiming struct {

	// pre_sync_duration is the time the service should wait before starting
	// setup.
	// For generators this would be the time the remote side needs to put itself
	// into loopback before generating packets.
	// For loopbacks this value would be expected to be zero or unset.
	PreSyncDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=pre_sync_duration,json=preSyncDuration,proto3" json:"pre_sync_duration,omitempty"`
	// The requested setup time for the endpoint. setup_duration must be >=
	// min_setup_duration in the service capabilities. If the service
	// completes setup before setup_duration it must wait setup_duration
	// before moving to qualification.
	SetupDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=setup_duration,json=setupDuration,proto3" json:"setup_duration,omitempty"`
	// duration is the length of the qualification.
	Duration *durationpb.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	// post_sync_duration is the amount time a side should wait before starting
	// its teardown.
	// For generators this value would be expected to be zero or unset.
	// For loopbacks this would be the duration it takes for the generator
	// to stop sending packets before starting a teardown.
	PostSyncDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=post_sync_duration,json=postSyncDuration,proto3" json:"post_sync_duration,omitempty"`
	// This requested teardown duration for the endpoint. teardown_duration
	// must be >= min_teardown_duration in the service capabilities. If the
	// service completes before the teardown_duration it must wait teardown
	// duration before completing.
	TeardownDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=teardown_duration,json=teardownDuration,proto3" json:"teardown_duration,omitempty"`
	// contains filtered or unexported fields
}

RPCSyncedTiming will be all synchronization by assuming the start rpc's are sent very close temporally with enough overlap in duration to get valid results. The pre_qual_wait will allow the caller to adjust any setup timing differences between peers. The post_qual_wait will allow for the caller to adjust any teardown differences in timing between peers. pre_qual_wait cannot be less than selected endpoint type's min_setup_time. post_qual_wait cannot be less than the selected endpoint type's min_teardown_time.

func (*RPCSyncedTiming) Descriptor deprecated

func (*RPCSyncedTiming) Descriptor() ([]byte, []int)

Deprecated: Use RPCSyncedTiming.ProtoReflect.Descriptor instead.

func (*RPCSyncedTiming) GetDuration

func (x *RPCSyncedTiming) GetDuration() *durationpb.Duration

func (*RPCSyncedTiming) GetPostSyncDuration

func (x *RPCSyncedTiming) GetPostSyncDuration() *durationpb.Duration

func (*RPCSyncedTiming) GetPreSyncDuration

func (x *RPCSyncedTiming) GetPreSyncDuration() *durationpb.Duration

func (*RPCSyncedTiming) GetSetupDuration

func (x *RPCSyncedTiming) GetSetupDuration() *durationpb.Duration

func (*RPCSyncedTiming) GetTeardownDuration

func (x *RPCSyncedTiming) GetTeardownDuration() *durationpb.Duration

func (*RPCSyncedTiming) ProtoMessage

func (*RPCSyncedTiming) ProtoMessage()

func (*RPCSyncedTiming) ProtoReflect

func (x *RPCSyncedTiming) ProtoReflect() protoreflect.Message

func (*RPCSyncedTiming) Reset

func (x *RPCSyncedTiming) Reset()

func (*RPCSyncedTiming) String

func (x *RPCSyncedTiming) String() string

type ReflectorCapabilities

type ReflectorCapabilities struct {
	PmdLoopback  *PmdLoopbackCapabilities  `protobuf:"bytes,1,opt,name=pmd_loopback,json=pmdLoopback,proto3" json:"pmd_loopback,omitempty"`
	AsicLoopback *AsicLoopbackCapabilities `protobuf:"bytes,2,opt,name=asic_loopback,json=asicLoopback,proto3" json:"asic_loopback,omitempty"`
	// contains filtered or unexported fields
}

If the service does not support any of the defined modes then the message should be unset.

func (*ReflectorCapabilities) Descriptor deprecated

func (*ReflectorCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use ReflectorCapabilities.ProtoReflect.Descriptor instead.

func (*ReflectorCapabilities) GetAsicLoopback

func (x *ReflectorCapabilities) GetAsicLoopback() *AsicLoopbackCapabilities

func (*ReflectorCapabilities) GetPmdLoopback

func (x *ReflectorCapabilities) GetPmdLoopback() *PmdLoopbackCapabilities

func (*ReflectorCapabilities) ProtoMessage

func (*ReflectorCapabilities) ProtoMessage()

func (*ReflectorCapabilities) ProtoReflect

func (x *ReflectorCapabilities) ProtoReflect() protoreflect.Message

func (*ReflectorCapabilities) Reset

func (x *ReflectorCapabilities) Reset()

func (*ReflectorCapabilities) String

func (x *ReflectorCapabilities) String() string

type UnimplementedLinkQualificationServer

type UnimplementedLinkQualificationServer struct {
}

UnimplementedLinkQualificationServer must be embedded to have forward compatible implementations.

func (UnimplementedLinkQualificationServer) Capabilities

func (UnimplementedLinkQualificationServer) Create

func (UnimplementedLinkQualificationServer) Delete

func (UnimplementedLinkQualificationServer) Get

func (UnimplementedLinkQualificationServer) List

type UnsafeLinkQualificationServer

type UnsafeLinkQualificationServer interface {
	// contains filtered or unexported methods
}

UnsafeLinkQualificationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LinkQualificationServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL