v1

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2024 License: Apache-2.0 Imports: 11 Imported by: 77

Documentation

Index

Constants

View Source 
const (
	P4Runtime_Write_FullMethodName                       = "/p4.v1.P4Runtime/Write"
	P4Runtime_Read_FullMethodName                        = "/p4.v1.P4Runtime/Read"
	P4Runtime_SetForwardingPipelineConfig_FullMethodName = "/p4.v1.P4Runtime/SetForwardingPipelineConfig"
	P4Runtime_GetForwardingPipelineConfig_FullMethodName = "/p4.v1.P4Runtime/GetForwardingPipelineConfig"
	P4Runtime_StreamChannel_FullMethodName               = "/p4.v1.P4Runtime/StreamChannel"
	P4Runtime_Capabilities_FullMethodName                = "/p4.v1.P4Runtime/Capabilities"
)

Variables

View Source 
var (
	SdnPort_name = map[int32]string{
		0:    "SDN_PORT_UNKNOWN",
		1:    "SDN_PORT_MIN",
		-257: "SDN_PORT_MAX",
		-6:   "SDN_PORT_RECIRCULATE",
		-3:   "SDN_PORT_CPU",
	}
	SdnPort_value = map[string]int32{
		"SDN_PORT_UNKNOWN":     0,
		"SDN_PORT_MIN":         1,
		"SDN_PORT_MAX":         -257,
		"SDN_PORT_RECIRCULATE": -6,
		"SDN_PORT_CPU":         -3,
	}
)

Enum value maps for SdnPort.

View Source 
var (
	WriteRequest_Atomicity_name = map[int32]string{
		0: "CONTINUE_ON_ERROR",
		1: "ROLLBACK_ON_ERROR",
		2: "DATAPLANE_ATOMIC",
	}
	WriteRequest_Atomicity_value = map[string]int32{
		"CONTINUE_ON_ERROR": 0,
		"ROLLBACK_ON_ERROR": 1,
		"DATAPLANE_ATOMIC":  2,
	}
)

Enum value maps for WriteRequest_Atomicity.

View Source 
var (
	Update_Type_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INSERT",
		2: "MODIFY",
		3: "DELETE",
	}
	Update_Type_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INSERT":      1,
		"MODIFY":      2,
		"DELETE":      3,
	}
)

Enum value maps for Update_Type.

View Source 
var (
	SetForwardingPipelineConfigRequest_Action_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "VERIFY",
		2: "VERIFY_AND_SAVE",
		3: "VERIFY_AND_COMMIT",
		4: "COMMIT",
		5: "RECONCILE_AND_COMMIT",
	}
	SetForwardingPipelineConfigRequest_Action_value = map[string]int32{
		"UNSPECIFIED":          0,
		"VERIFY":               1,
		"VERIFY_AND_SAVE":      2,
		"VERIFY_AND_COMMIT":    3,
		"COMMIT":               4,
		"RECONCILE_AND_COMMIT": 5,
	}
)

Enum value maps for SetForwardingPipelineConfigRequest_Action.

View Source 
var (
	GetForwardingPipelineConfigRequest_ResponseType_name = map[int32]string{
		0: "ALL",
		1: "COOKIE_ONLY",
		2: "P4INFO_AND_COOKIE",
		3: "DEVICE_CONFIG_AND_COOKIE",
	}
	GetForwardingPipelineConfigRequest_ResponseType_value = map[string]int32{
		"ALL":                      0,
		"COOKIE_ONLY":              1,
		"P4INFO_AND_COOKIE":        2,
		"DEVICE_CONFIG_AND_COOKIE": 3,
	}
)

Enum value maps for GetForwardingPipelineConfigRequest_ResponseType.

View Source 
var File_p4_v1_p4data_proto protoreflect.FileDescriptor
View Source 
var File_p4_v1_p4runtime_proto protoreflect.FileDescriptor
View Source 
var P4Runtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "p4.v1.P4Runtime",
	HandlerType: (*P4RuntimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _P4Runtime_Write_Handler,
		},
		{
			MethodName: "SetForwardingPipelineConfig",
			Handler:    _P4Runtime_SetForwardingPipelineConfig_Handler,
		},
		{
			MethodName: "GetForwardingPipelineConfig",
			Handler:    _P4Runtime_GetForwardingPipelineConfig_Handler,
		},
		{
			MethodName: "Capabilities",
			Handler:    _P4Runtime_Capabilities_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Read",
			Handler:       _P4Runtime_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamChannel",
			Handler:       _P4Runtime_StreamChannel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "p4/v1/p4runtime.proto",
}

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

Functions

func RegisterP4RuntimeServer 

func RegisterP4RuntimeServer(s grpc.ServiceRegistrar, srv P4RuntimeServer)

Types

type Action 

type Action struct {
	ActionId uint32          `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	Params   []*Action_Param `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetActionId 

func (x *Action) GetActionId() uint32

func (*Action) GetParams 

func (x *Action) GetParams() []*Action_Param

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect added in v1.4.0 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionProfileAction 

type ActionProfileAction struct {
	Action *Action `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Weight int32   `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// Types that are assignable to WatchKind:
	//
	//	*ActionProfileAction_Watch
	//	*ActionProfileAction_WatchPort
	WatchKind isActionProfileAction_WatchKind `protobuf_oneof:"watch_kind"`
	// contains filtered or unexported fields
}

func (*ActionProfileAction) Descriptor deprecated 

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

Deprecated: Use ActionProfileAction.ProtoReflect.Descriptor instead.

func (*ActionProfileAction) GetAction 

func (x *ActionProfileAction) GetAction() *Action

func (*ActionProfileAction) GetWatch deprecated 

func (x *ActionProfileAction) GetWatch() int32

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*ActionProfileAction) GetWatchKind added in v1.3.0 

func (m *ActionProfileAction) GetWatchKind() isActionProfileAction_WatchKind

func (*ActionProfileAction) GetWatchPort added in v1.3.0 

func (x *ActionProfileAction) GetWatchPort() []byte

func (*ActionProfileAction) GetWeight 

func (x *ActionProfileAction) GetWeight() int32

func (*ActionProfileAction) ProtoMessage 

func (*ActionProfileAction) ProtoMessage()

func (*ActionProfileAction) ProtoReflect added in v1.4.0 

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

func (*ActionProfileAction) Reset 

func (x *ActionProfileAction) Reset()

func (*ActionProfileAction) String 

func (x *ActionProfileAction) String() string

type ActionProfileActionSet 

type ActionProfileActionSet struct {
	ActionProfileActions []*ActionProfileAction `protobuf:"bytes,1,rep,name=action_profile_actions,json=actionProfileActions,proto3" json:"action_profile_actions,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionProfileActionSet) Descriptor deprecated 

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

Deprecated: Use ActionProfileActionSet.ProtoReflect.Descriptor instead.

func (*ActionProfileActionSet) GetActionProfileActions 

func (x *ActionProfileActionSet) GetActionProfileActions() []*ActionProfileAction

func (*ActionProfileActionSet) ProtoMessage 

func (*ActionProfileActionSet) ProtoMessage()

func (*ActionProfileActionSet) ProtoReflect added in v1.4.0 

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

func (*ActionProfileActionSet) Reset 

func (x *ActionProfileActionSet) Reset()

func (*ActionProfileActionSet) String 

func (x *ActionProfileActionSet) String() string

type ActionProfileAction_Watch added in v1.3.0 

type ActionProfileAction_Watch struct {
	// Using int32 as ports is deprecated, use watch_port instead.
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	Watch int32 `protobuf:"varint,3,opt,name=watch,proto3,oneof"`
}

type ActionProfileAction_WatchPort added in v1.3.0 

type ActionProfileAction_WatchPort struct {
	WatchPort []byte `protobuf:"bytes,4,opt,name=watch_port,json=watchPort,proto3,oneof"`
}

type ActionProfileGroup 

type ActionProfileGroup struct {
	ActionProfileId uint32                       `protobuf:"varint,1,opt,name=action_profile_id,json=actionProfileId,proto3" json:"action_profile_id,omitempty"`
	GroupId         uint32                       `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Members         []*ActionProfileGroup_Member `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	// Max number of weighted member entries in this group. It cannot be modified
	// after a group has been created. It must not exceed the static
	// max_group_size included in P4Info. If the max size is not known at group
	// creation-time, the client may leave this field unset (default value 0), in
	// which case the static max_group_size value will be used and the group will
	// be able to include up to max_group_size weighted member entries.
	MaxSize int32 `protobuf:"varint,4,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*ActionProfileGroup) Descriptor deprecated 

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

Deprecated: Use ActionProfileGroup.ProtoReflect.Descriptor instead.

func (*ActionProfileGroup) GetActionProfileId 

func (x *ActionProfileGroup) GetActionProfileId() uint32

func (*ActionProfileGroup) GetGroupId 

func (x *ActionProfileGroup) GetGroupId() uint32

func (*ActionProfileGroup) GetMaxSize 

func (x *ActionProfileGroup) GetMaxSize() int32

func (*ActionProfileGroup) GetMembers 

func (x *ActionProfileGroup) GetMembers() []*ActionProfileGroup_Member

func (*ActionProfileGroup) ProtoMessage 

func (*ActionProfileGroup) ProtoMessage()

func (*ActionProfileGroup) ProtoReflect added in v1.4.0 

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

func (*ActionProfileGroup) Reset 

func (x *ActionProfileGroup) Reset()

func (*ActionProfileGroup) String 

func (x *ActionProfileGroup) String() string

type ActionProfileGroup_Member 

type ActionProfileGroup_Member struct {
	MemberId uint32 `protobuf:"varint,1,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Weight   int32  `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// Types that are assignable to WatchKind:
	//
	//	*ActionProfileGroup_Member_Watch
	//	*ActionProfileGroup_Member_WatchPort
	WatchKind isActionProfileGroup_Member_WatchKind `protobuf_oneof:"watch_kind"`
	// contains filtered or unexported fields
}

func (*ActionProfileGroup_Member) Descriptor deprecated 

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

Deprecated: Use ActionProfileGroup_Member.ProtoReflect.Descriptor instead.

func (*ActionProfileGroup_Member) GetMemberId 

func (x *ActionProfileGroup_Member) GetMemberId() uint32

func (*ActionProfileGroup_Member) GetWatch deprecated 

func (x *ActionProfileGroup_Member) GetWatch() int32

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*ActionProfileGroup_Member) GetWatchKind added in v1.3.0 

func (m *ActionProfileGroup_Member) GetWatchKind() isActionProfileGroup_Member_WatchKind

func (*ActionProfileGroup_Member) GetWatchPort added in v1.3.0 

func (x *ActionProfileGroup_Member) GetWatchPort() []byte

func (*ActionProfileGroup_Member) GetWeight 

func (x *ActionProfileGroup_Member) GetWeight() int32

func (*ActionProfileGroup_Member) ProtoMessage 

func (*ActionProfileGroup_Member) ProtoMessage()

func (*ActionProfileGroup_Member) ProtoReflect added in v1.4.0 

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

func (*ActionProfileGroup_Member) Reset 

func (x *ActionProfileGroup_Member) Reset()

func (*ActionProfileGroup_Member) String 

func (x *ActionProfileGroup_Member) String() string

type ActionProfileGroup_Member_Watch added in v1.3.0 

type ActionProfileGroup_Member_Watch struct {
	// Using int32 as ports is deprecated, use watch_port instead.
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	Watch int32 `protobuf:"varint,3,opt,name=watch,proto3,oneof"`
}

type ActionProfileGroup_Member_WatchPort added in v1.3.0 

type ActionProfileGroup_Member_WatchPort struct {
	WatchPort []byte `protobuf:"bytes,4,opt,name=watch_port,json=watchPort,proto3,oneof"`
}

type ActionProfileMember 

type ActionProfileMember struct {
	ActionProfileId uint32  `protobuf:"varint,1,opt,name=action_profile_id,json=actionProfileId,proto3" json:"action_profile_id,omitempty"`
	MemberId        uint32  `protobuf:"varint,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Action          *Action `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*ActionProfileMember) Descriptor deprecated 

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

Deprecated: Use ActionProfileMember.ProtoReflect.Descriptor instead.

func (*ActionProfileMember) GetAction 

func (x *ActionProfileMember) GetAction() *Action

func (*ActionProfileMember) GetActionProfileId 

func (x *ActionProfileMember) GetActionProfileId() uint32

func (*ActionProfileMember) GetMemberId 

func (x *ActionProfileMember) GetMemberId() uint32

func (*ActionProfileMember) ProtoMessage 

func (*ActionProfileMember) ProtoMessage()

func (*ActionProfileMember) ProtoReflect added in v1.4.0 

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

func (*ActionProfileMember) Reset 

func (x *ActionProfileMember) Reset()

func (*ActionProfileMember) String 

func (x *ActionProfileMember) String() string

type Action_Param 

type Action_Param struct {
	ParamId uint32 `protobuf:"varint,2,opt,name=param_id,json=paramId,proto3" json:"param_id,omitempty"`
	Value   []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_Param) Descriptor deprecated 

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

Deprecated: Use Action_Param.ProtoReflect.Descriptor instead.

func (*Action_Param) GetParamId 

func (x *Action_Param) GetParamId() uint32

func (*Action_Param) GetValue 

func (x *Action_Param) GetValue() []byte

func (*Action_Param) ProtoMessage 

func (*Action_Param) ProtoMessage()

func (*Action_Param) ProtoReflect added in v1.4.0 

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

func (*Action_Param) Reset 

func (x *Action_Param) Reset()

func (*Action_Param) String 

func (x *Action_Param) 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 added in v1.4.0 

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 {

	// The full semantic version string (e.g. "1.1.0-rc.1") corresponding to the
	// version of the P4Runtime API currently implemented by the server.
	P4RuntimeApiVersion string `protobuf:"bytes,1,opt,name=p4runtime_api_version,json=p4runtimeApiVersion,proto3" json:"p4runtime_api_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CapabilitiesResponse) Descriptor deprecated 

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

Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*CapabilitiesResponse) GetP4RuntimeApiVersion 

func (x *CapabilitiesResponse) GetP4RuntimeApiVersion() string

func (*CapabilitiesResponse) ProtoMessage 

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) ProtoReflect added in v1.4.0 

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

func (*CapabilitiesResponse) Reset 

func (x *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) String 

func (x *CapabilitiesResponse) String() string

type CloneSessionEntry 

type CloneSessionEntry struct {
	SessionId         uint32     `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Replicas          []*Replica `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	ClassOfService    uint32     `protobuf:"varint,3,opt,name=class_of_service,json=classOfService,proto3" json:"class_of_service,omitempty"`
	PacketLengthBytes int32      `protobuf:"varint,4,opt,name=packet_length_bytes,json=packetLengthBytes,proto3" json:"packet_length_bytes,omitempty"`
	// contains filtered or unexported fields
}

A packet may be cloned by setting the clone_session_id field of PSA ingress/egress output metadata to session_id of a programmed clone session entry. Multiple clones may be created via a single clone session entry by using the replicas message. The clones may be distinguished in the egress using the instance field. The class_of_service field of the clone's egress input metadata will be set to the respective value programmed in the clone session entry. Note that in case of multiple clones, all clones, defined for a clone session, will get the same class of service. The packet_length_bytes field must be set to a non-zero value if the clone packet(s) should be truncated to the given value (in bytes). The packet length is also common to all clones in the clone session. If the packet_length_bytes field is 0, no truncation on the clone(s) will be performed.

func (*CloneSessionEntry) Descriptor deprecated 

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

Deprecated: Use CloneSessionEntry.ProtoReflect.Descriptor instead.

func (*CloneSessionEntry) GetClassOfService 

func (x *CloneSessionEntry) GetClassOfService() uint32

func (*CloneSessionEntry) GetPacketLengthBytes 

func (x *CloneSessionEntry) GetPacketLengthBytes() int32

func (*CloneSessionEntry) GetReplicas 

func (x *CloneSessionEntry) GetReplicas() []*Replica

func (*CloneSessionEntry) GetSessionId 

func (x *CloneSessionEntry) GetSessionId() uint32

func (*CloneSessionEntry) ProtoMessage 

func (*CloneSessionEntry) ProtoMessage()

func (*CloneSessionEntry) ProtoReflect added in v1.4.0 

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

func (*CloneSessionEntry) Reset 

func (x *CloneSessionEntry) Reset()

func (*CloneSessionEntry) String 

func (x *CloneSessionEntry) String() string

type CounterData 

type CounterData struct {
	ByteCount   int64 `protobuf:"varint,1,opt,name=byte_count,json=byteCount,proto3" json:"byte_count,omitempty"`
	PacketCount int64 `protobuf:"varint,2,opt,name=packet_count,json=packetCount,proto3" json:"packet_count,omitempty"`
	// contains filtered or unexported fields
}

func (*CounterData) Descriptor deprecated 

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

Deprecated: Use CounterData.ProtoReflect.Descriptor instead.

func (*CounterData) GetByteCount 

func (x *CounterData) GetByteCount() int64

func (*CounterData) GetPacketCount 

func (x *CounterData) GetPacketCount() int64

func (*CounterData) ProtoMessage 

func (*CounterData) ProtoMessage()

func (*CounterData) ProtoReflect added in v1.4.0 

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

func (*CounterData) Reset 

func (x *CounterData) Reset()

func (*CounterData) String 

func (x *CounterData) String() string

type CounterEntry 

type CounterEntry struct {
	CounterId uint32       `protobuf:"varint,1,opt,name=counter_id,json=counterId,proto3" json:"counter_id,omitempty"`
	Index     *Index       `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	Data      *CounterData `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ For WriteRequest, Update.Type must be MODIFY. For ReadRequest, the scope is defined as follows: - All counter cells for all counters if counter_id = 0 (default). - All counter cells for given counter_id if index is unset (default).

func (*CounterEntry) Descriptor deprecated 

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

Deprecated: Use CounterEntry.ProtoReflect.Descriptor instead.

func (*CounterEntry) GetCounterId 

func (x *CounterEntry) GetCounterId() uint32

func (*CounterEntry) GetData 

func (x *CounterEntry) GetData() *CounterData

func (*CounterEntry) GetIndex 

func (x *CounterEntry) GetIndex() *Index

func (*CounterEntry) ProtoMessage 

func (*CounterEntry) ProtoMessage()

func (*CounterEntry) ProtoReflect added in v1.4.0 

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

func (*CounterEntry) Reset 

func (x *CounterEntry) Reset()

func (*CounterEntry) String 

func (x *CounterEntry) String() string

type DigestEntry 

type DigestEntry struct {
	DigestId uint32              `protobuf:"varint,1,opt,name=digest_id,json=digestId,proto3" json:"digest_id,omitempty"`
	Config   *DigestEntry_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ Used to configure the digest extern only, not to stream digests or acks

func (*DigestEntry) Descriptor deprecated 

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

Deprecated: Use DigestEntry.ProtoReflect.Descriptor instead.

func (*DigestEntry) GetConfig 

func (x *DigestEntry) GetConfig() *DigestEntry_Config

func (*DigestEntry) GetDigestId 

func (x *DigestEntry) GetDigestId() uint32

func (*DigestEntry) ProtoMessage 

func (*DigestEntry) ProtoMessage()

func (*DigestEntry) ProtoReflect added in v1.4.0 

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

func (*DigestEntry) Reset 

func (x *DigestEntry) Reset()

func (*DigestEntry) String 

func (x *DigestEntry) String() string

type DigestEntry_Config 

type DigestEntry_Config struct {
	MaxTimeoutNs int64 `protobuf:"varint,1,opt,name=max_timeout_ns,json=maxTimeoutNs,proto3" json:"max_timeout_ns,omitempty"` // max timeout for outstanding digest data
	MaxListSize  int32 `protobuf:"varint,2,opt,name=max_list_size,json=maxListSize,proto3" json:"max_list_size,omitempty"`    // max size for a digest list
	AckTimeoutNs int64 `protobuf:"varint,3,opt,name=ack_timeout_ns,json=ackTimeoutNs,proto3" json:"ack_timeout_ns,omitempty"` // timeout for DigestListAck message
	// contains filtered or unexported fields
}

a DigestList message is streamed when the following conditions are met:

  • there is at least one digest ready
  • the oldest digest in the list has been waiting for at least max_timeout_ns nanoseconds or we have gathered max_list_size digests already

func (*DigestEntry_Config) Descriptor deprecated 

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

Deprecated: Use DigestEntry_Config.ProtoReflect.Descriptor instead.

func (*DigestEntry_Config) GetAckTimeoutNs 

func (x *DigestEntry_Config) GetAckTimeoutNs() int64

func (*DigestEntry_Config) GetMaxListSize 

func (x *DigestEntry_Config) GetMaxListSize() int32

func (*DigestEntry_Config) GetMaxTimeoutNs 

func (x *DigestEntry_Config) GetMaxTimeoutNs() int64

func (*DigestEntry_Config) ProtoMessage 

func (*DigestEntry_Config) ProtoMessage()

func (*DigestEntry_Config) ProtoReflect added in v1.4.0 

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

func (*DigestEntry_Config) Reset 

func (x *DigestEntry_Config) Reset()

func (*DigestEntry_Config) String 

func (x *DigestEntry_Config) String() string

type DigestList 

type DigestList struct {
	DigestId uint32 `protobuf:"varint,1,opt,name=digest_id,json=digestId,proto3" json:"digest_id,omitempty"` // identifies the digest extern instance
	ListId   uint64 `protobuf:"varint,2,opt,name=list_id,json=listId,proto3" json:"list_id,omitempty"`       // identifies a list of entries, used by receiver to ack
	// List of entries: each call to the Digest<T>::pack() method corresponds to
	// one entry and we can have as little as one entry.
	Data []*P4Data `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	// Timestamp at which the server generated the message (in nanoseconds since
	// Epoch)
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*DigestList) Descriptor deprecated 

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

Deprecated: Use DigestList.ProtoReflect.Descriptor instead.

func (*DigestList) GetData 

func (x *DigestList) GetData() []*P4Data

func (*DigestList) GetDigestId 

func (x *DigestList) GetDigestId() uint32

func (*DigestList) GetListId 

func (x *DigestList) GetListId() uint64

func (*DigestList) GetTimestamp 

func (x *DigestList) GetTimestamp() int64

func (*DigestList) ProtoMessage 

func (*DigestList) ProtoMessage()

func (*DigestList) ProtoReflect added in v1.4.0 

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

func (*DigestList) Reset 

func (x *DigestList) Reset()

func (*DigestList) String 

func (x *DigestList) String() string

type DigestListAck 

type DigestListAck struct {
	DigestId uint32 `protobuf:"varint,1,opt,name=digest_id,json=digestId,proto3" json:"digest_id,omitempty"`
	ListId   uint64 `protobuf:"varint,2,opt,name=list_id,json=listId,proto3" json:"list_id,omitempty"`
	// contains filtered or unexported fields
}

Used by the controller to ack a DigestList message. To avoid flooding the controller, the switch must not generate digest notifications for the same data until a DigestListAck message with the same list_id is received or the ack timeout (ack_timeout_ns field in DigestEntry.Config) expires.

func (*DigestListAck) Descriptor deprecated 

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

Deprecated: Use DigestListAck.ProtoReflect.Descriptor instead.

func (*DigestListAck) GetDigestId 

func (x *DigestListAck) GetDigestId() uint32

func (*DigestListAck) GetListId 

func (x *DigestListAck) GetListId() uint64

func (*DigestListAck) ProtoMessage 

func (*DigestListAck) ProtoMessage()

func (*DigestListAck) ProtoReflect added in v1.4.0 

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

func (*DigestListAck) Reset 

func (x *DigestListAck) Reset()

func (*DigestListAck) String 

func (x *DigestListAck) String() string

type DigestListAckError 

type DigestListAckError struct {

	// Optional. The digest list acknowledgement message that caused the error.
	DigestListAck *DigestListAck `protobuf:"bytes,1,opt,name=digest_list_ack,json=digestListAck,proto3" json:"digest_list_ack,omitempty"`
	// contains filtered or unexported fields
}

func (*DigestListAckError) Descriptor deprecated 

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

Deprecated: Use DigestListAckError.ProtoReflect.Descriptor instead.

func (*DigestListAckError) GetDigestListAck 

func (x *DigestListAckError) GetDigestListAck() *DigestListAck

func (*DigestListAckError) ProtoMessage 

func (*DigestListAckError) ProtoMessage()

func (*DigestListAckError) ProtoReflect added in v1.4.0 

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

func (*DigestListAckError) Reset 

func (x *DigestListAckError) Reset()

func (*DigestListAckError) String 

func (x *DigestListAckError) String() string

type DirectCounterEntry 

type DirectCounterEntry struct {

	// The associated table entry. This field is required.
	// table_entry.action is ignored. Other fields specify the match.
	TableEntry *TableEntry  `protobuf:"bytes,1,opt,name=table_entry,json=tableEntry,proto3" json:"table_entry,omitempty"`
	Data       *CounterData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ For WriteRequest, Update.Type must be MODIFY. INSERT and DELETE on direct counters is not allowed and will return an error. The insertion/deletion should happen as part of INSERT/DELETE on the associated table-entry. For ReadRequest, the scope is defined as follows:

  • All counter cells for all tables if table_entry.table_id = 0.
  • All counter cells of a table if table_entry.table_id is present and table_entry.match is empty.

func (*DirectCounterEntry) Descriptor deprecated 

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

Deprecated: Use DirectCounterEntry.ProtoReflect.Descriptor instead.

func (*DirectCounterEntry) GetData 

func (x *DirectCounterEntry) GetData() *CounterData

func (*DirectCounterEntry) GetTableEntry 

func (x *DirectCounterEntry) GetTableEntry() *TableEntry

func (*DirectCounterEntry) ProtoMessage 

func (*DirectCounterEntry) ProtoMessage()

func (*DirectCounterEntry) ProtoReflect added in v1.4.0 

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

func (*DirectCounterEntry) Reset 

func (x *DirectCounterEntry) Reset()

func (*DirectCounterEntry) String 

func (x *DirectCounterEntry) String() string

type DirectMeterEntry 

type DirectMeterEntry struct {

	// The associated table entry. This field is required.
	// table_entry.action is ignored. Other fields specify the match.
	TableEntry *TableEntry  `protobuf:"bytes,1,opt,name=table_entry,json=tableEntry,proto3" json:"table_entry,omitempty"`
	Config     *MeterConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Added in v1.4.0
	CounterData *MeterCounterData `protobuf:"bytes,3,opt,name=counter_data,json=counterData,proto3" json:"counter_data,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ For WriteRequest, Update.Type must be MODIFY. INSERT and DELETE on direct meters is not allowed and will return an error. The insertion/deletion should happen as part of INSERT/DELETE on the associated table-entry. For ReadRequest, the scope is defined as follows:

  • All meter cells for all tables if table_entry.table_id = 0.
  • All meter cells of a table if table_entry.table_id is present and table_entry.match is empty.

func (*DirectMeterEntry) Descriptor deprecated 

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

Deprecated: Use DirectMeterEntry.ProtoReflect.Descriptor instead.

func (*DirectMeterEntry) GetConfig 

func (x *DirectMeterEntry) GetConfig() *MeterConfig

func (*DirectMeterEntry) GetCounterData added in v1.4.0 

func (x *DirectMeterEntry) GetCounterData() *MeterCounterData

func (*DirectMeterEntry) GetTableEntry 

func (x *DirectMeterEntry) GetTableEntry() *TableEntry

func (*DirectMeterEntry) ProtoMessage 

func (*DirectMeterEntry) ProtoMessage()

func (*DirectMeterEntry) ProtoReflect added in v1.4.0 

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

func (*DirectMeterEntry) Reset 

func (x *DirectMeterEntry) Reset()

func (*DirectMeterEntry) String 

func (x *DirectMeterEntry) String() string

type Entity 

type Entity struct {

	// Types that are assignable to Entity:
	//
	//	*Entity_ExternEntry
	//	*Entity_TableEntry
	//	*Entity_ActionProfileMember
	//	*Entity_ActionProfileGroup
	//	*Entity_MeterEntry
	//	*Entity_DirectMeterEntry
	//	*Entity_CounterEntry
	//	*Entity_DirectCounterEntry
	//	*Entity_PacketReplicationEngineEntry
	//	*Entity_ValueSetEntry
	//	*Entity_RegisterEntry
	//	*Entity_DigestEntry
	Entity isEntity_Entity `protobuf_oneof:"entity"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetActionProfileGroup 

func (x *Entity) GetActionProfileGroup() *ActionProfileGroup

func (*Entity) GetActionProfileMember 

func (x *Entity) GetActionProfileMember() *ActionProfileMember

func (*Entity) GetCounterEntry 

func (x *Entity) GetCounterEntry() *CounterEntry

func (*Entity) GetDigestEntry 

func (x *Entity) GetDigestEntry() *DigestEntry

func (*Entity) GetDirectCounterEntry 

func (x *Entity) GetDirectCounterEntry() *DirectCounterEntry

func (*Entity) GetDirectMeterEntry 

func (x *Entity) GetDirectMeterEntry() *DirectMeterEntry

func (*Entity) GetEntity 

func (m *Entity) GetEntity() isEntity_Entity

func (*Entity) GetExternEntry 

func (x *Entity) GetExternEntry() *ExternEntry

func (*Entity) GetMeterEntry 

func (x *Entity) GetMeterEntry() *MeterEntry

func (*Entity) GetPacketReplicationEngineEntry 

func (x *Entity) GetPacketReplicationEngineEntry() *PacketReplicationEngineEntry

func (*Entity) GetRegisterEntry 

func (x *Entity) GetRegisterEntry() *RegisterEntry

func (*Entity) GetTableEntry 

func (x *Entity) GetTableEntry() *TableEntry

func (*Entity) GetValueSetEntry 

func (x *Entity) GetValueSetEntry() *ValueSetEntry

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect added in v1.4.0 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type Entity_ActionProfileGroup 

type Entity_ActionProfileGroup struct {
	ActionProfileGroup *ActionProfileGroup `protobuf:"bytes,4,opt,name=action_profile_group,json=actionProfileGroup,proto3,oneof"`
}

type Entity_ActionProfileMember 

type Entity_ActionProfileMember struct {
	ActionProfileMember *ActionProfileMember `protobuf:"bytes,3,opt,name=action_profile_member,json=actionProfileMember,proto3,oneof"`
}

type Entity_CounterEntry 

type Entity_CounterEntry struct {
	CounterEntry *CounterEntry `protobuf:"bytes,7,opt,name=counter_entry,json=counterEntry,proto3,oneof"`
}

type Entity_DigestEntry 

type Entity_DigestEntry struct {
	DigestEntry *DigestEntry `protobuf:"bytes,12,opt,name=digest_entry,json=digestEntry,proto3,oneof"`
}

type Entity_DirectCounterEntry 

type Entity_DirectCounterEntry struct {
	DirectCounterEntry *DirectCounterEntry `protobuf:"bytes,8,opt,name=direct_counter_entry,json=directCounterEntry,proto3,oneof"`
}

type Entity_DirectMeterEntry 

type Entity_DirectMeterEntry struct {
	DirectMeterEntry *DirectMeterEntry `protobuf:"bytes,6,opt,name=direct_meter_entry,json=directMeterEntry,proto3,oneof"`
}

type Entity_ExternEntry 

type Entity_ExternEntry struct {
	ExternEntry *ExternEntry `protobuf:"bytes,1,opt,name=extern_entry,json=externEntry,proto3,oneof"`
}

type Entity_MeterEntry 

type Entity_MeterEntry struct {
	MeterEntry *MeterEntry `protobuf:"bytes,5,opt,name=meter_entry,json=meterEntry,proto3,oneof"`
}

type Entity_PacketReplicationEngineEntry 

type Entity_PacketReplicationEngineEntry struct {
	PacketReplicationEngineEntry *PacketReplicationEngineEntry `protobuf:"bytes,9,opt,name=packet_replication_engine_entry,json=packetReplicationEngineEntry,proto3,oneof"`
}

type Entity_RegisterEntry 

type Entity_RegisterEntry struct {
	RegisterEntry *RegisterEntry `protobuf:"bytes,11,opt,name=register_entry,json=registerEntry,proto3,oneof"`
}

type Entity_TableEntry 

type Entity_TableEntry struct {
	TableEntry *TableEntry `protobuf:"bytes,2,opt,name=table_entry,json=tableEntry,proto3,oneof"`
}

type Entity_ValueSetEntry 

type Entity_ValueSetEntry struct {
	ValueSetEntry *ValueSetEntry `protobuf:"bytes,10,opt,name=value_set_entry,json=valueSetEntry,proto3,oneof"`
}

type Error 

type Error struct {

	// gRPC canonical error code (see
	// https://developers.google.com/maps-booking/reference/grpc-api/status_codes)
	CanonicalCode int32 `protobuf:"varint,1,opt,name=canonical_code,json=canonicalCode,proto3" json:"canonical_code,omitempty"`
	// Detailed error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Target and architecture specific space to which this error belongs.
	// We encourage using triplet: <target>-<arch>-<vendor>,
	// e.g."targetX-psa-vendor1" or "targetY-psa-vendor2".
	Space string `protobuf:"bytes,3,opt,name=space,proto3" json:"space,omitempty"`
	// Numeric code drawn from target-specific error space above.
	Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	// Optional: Allows reporting back additional target-specific details on the
	// error.
	Details *anypb.Any `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Error message used to report a single P4-entity error for a Write RPC.

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCanonicalCode 

func (x *Error) GetCanonicalCode() int32

func (*Error) GetCode 

func (x *Error) GetCode() int32

func (*Error) GetDetails 

func (x *Error) GetDetails() *anypb.Any

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetSpace 

func (x *Error) GetSpace() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v1.4.0 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type ExternEntry 

type ExternEntry struct {

	// the extern_type_id is unique for a given architecture and must be in the
	// range [0x81, 0xfe].
	ExternTypeId uint32     `protobuf:"varint,1,opt,name=extern_type_id,json=externTypeId,proto3" json:"extern_type_id,omitempty"`
	ExternId     uint32     `protobuf:"varint,2,opt,name=extern_id,json=externId,proto3" json:"extern_id,omitempty"` // id of the instance
	Entry        *anypb.Any `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternEntry) Descriptor deprecated 

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

Deprecated: Use ExternEntry.ProtoReflect.Descriptor instead.

func (*ExternEntry) GetEntry 

func (x *ExternEntry) GetEntry() *anypb.Any

func (*ExternEntry) GetExternId 

func (x *ExternEntry) GetExternId() uint32

func (*ExternEntry) GetExternTypeId 

func (x *ExternEntry) GetExternTypeId() uint32

func (*ExternEntry) ProtoMessage 

func (*ExternEntry) ProtoMessage()

func (*ExternEntry) ProtoReflect added in v1.4.0 

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

func (*ExternEntry) Reset 

func (x *ExternEntry) Reset()

func (*ExternEntry) String 

func (x *ExternEntry) String() string

type FieldMatch 

type FieldMatch struct {
	FieldId uint32 `protobuf:"varint,1,opt,name=field_id,json=fieldId,proto3" json:"field_id,omitempty"`
	// Types that are assignable to FieldMatchType:
	//
	//	*FieldMatch_Exact_
	//	*FieldMatch_Ternary_
	//	*FieldMatch_Lpm
	//	*FieldMatch_Range_
	//	*FieldMatch_Optional_
	//	*FieldMatch_Other
	FieldMatchType isFieldMatch_FieldMatchType `protobuf_oneof:"field_match_type"`
	// contains filtered or unexported fields
}

field_match_type ::= exact | ternary | lpm | range | optional

func (*FieldMatch) Descriptor deprecated 

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

Deprecated: Use FieldMatch.ProtoReflect.Descriptor instead.

func (*FieldMatch) GetExact 

func (x *FieldMatch) GetExact() *FieldMatch_Exact

func (*FieldMatch) GetFieldId 

func (x *FieldMatch) GetFieldId() uint32

func (*FieldMatch) GetFieldMatchType 

func (m *FieldMatch) GetFieldMatchType() isFieldMatch_FieldMatchType

func (*FieldMatch) GetLpm 

func (x *FieldMatch) GetLpm() *FieldMatch_LPM

func (*FieldMatch) GetOptional 

func (x *FieldMatch) GetOptional() *FieldMatch_Optional

func (*FieldMatch) GetOther 

func (x *FieldMatch) GetOther() *anypb.Any

func (*FieldMatch) GetRange 

func (x *FieldMatch) GetRange() *FieldMatch_Range

func (*FieldMatch) GetTernary 

func (x *FieldMatch) GetTernary() *FieldMatch_Ternary

func (*FieldMatch) ProtoMessage 

func (*FieldMatch) ProtoMessage()

func (*FieldMatch) ProtoReflect added in v1.4.0 

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

func (*FieldMatch) Reset 

func (x *FieldMatch) Reset()

func (*FieldMatch) String 

func (x *FieldMatch) String() string

type FieldMatch_Exact 

type FieldMatch_Exact struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Matches can be performed on arbitrarily-large inputs; the protobuf type 'bytes' is used to model arbitrarily-large values.

func (*FieldMatch_Exact) Descriptor deprecated 

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

Deprecated: Use FieldMatch_Exact.ProtoReflect.Descriptor instead.

func (*FieldMatch_Exact) GetValue 

func (x *FieldMatch_Exact) GetValue() []byte

func (*FieldMatch_Exact) ProtoMessage 

func (*FieldMatch_Exact) ProtoMessage()

func (*FieldMatch_Exact) ProtoReflect added in v1.4.0 

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

func (*FieldMatch_Exact) Reset 

func (x *FieldMatch_Exact) Reset()

func (*FieldMatch_Exact) String 

func (x *FieldMatch_Exact) String() string

type FieldMatch_Exact_ 

type FieldMatch_Exact_ struct {
	Exact *FieldMatch_Exact `protobuf:"bytes,2,opt,name=exact,proto3,oneof"`
}

type FieldMatch_LPM 

type FieldMatch_LPM struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	PrefixLen int32  `protobuf:"varint,2,opt,name=prefix_len,json=prefixLen,proto3" json:"prefix_len,omitempty"` // in bits
	// contains filtered or unexported fields
}

func (*FieldMatch_LPM) Descriptor deprecated 

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

Deprecated: Use FieldMatch_LPM.ProtoReflect.Descriptor instead.

func (*FieldMatch_LPM) GetPrefixLen 

func (x *FieldMatch_LPM) GetPrefixLen() int32

func (*FieldMatch_LPM) GetValue 

func (x *FieldMatch_LPM) GetValue() []byte

func (*FieldMatch_LPM) ProtoMessage 

func (*FieldMatch_LPM) ProtoMessage()

func (*FieldMatch_LPM) ProtoReflect added in v1.4.0 

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

func (*FieldMatch_LPM) Reset 

func (x *FieldMatch_LPM) Reset()

func (*FieldMatch_LPM) String 

func (x *FieldMatch_LPM) String() string

type FieldMatch_Lpm 

type FieldMatch_Lpm struct {
	Lpm *FieldMatch_LPM `protobuf:"bytes,4,opt,name=lpm,proto3,oneof"`
}

type FieldMatch_Optional 

type FieldMatch_Optional struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

If the Optional match should be a wildcard, the FieldMatch must be omitted. Otherwise, this behaves like an exact match.

func (*FieldMatch_Optional) Descriptor deprecated 

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

Deprecated: Use FieldMatch_Optional.ProtoReflect.Descriptor instead.

func (*FieldMatch_Optional) GetValue 

func (x *FieldMatch_Optional) GetValue() []byte

func (*FieldMatch_Optional) ProtoMessage 

func (*FieldMatch_Optional) ProtoMessage()

func (*FieldMatch_Optional) ProtoReflect added in v1.4.0 

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

func (*FieldMatch_Optional) Reset 

func (x *FieldMatch_Optional) Reset()

func (*FieldMatch_Optional) String 

func (x *FieldMatch_Optional) String() string

type FieldMatch_Optional_ 

type FieldMatch_Optional_ struct {
	Optional *FieldMatch_Optional `protobuf:"bytes,7,opt,name=optional,proto3,oneof"`
}

type FieldMatch_Other 

type FieldMatch_Other struct {
	// Architecture-specific match value; it corresponds to the other_match_type
	// in the P4Info MatchField message.
	Other *anypb.Any `protobuf:"bytes,100,opt,name=other,proto3,oneof"`
}

type FieldMatch_Range 

type FieldMatch_Range struct {
	Low  []byte `protobuf:"bytes,1,opt,name=low,proto3" json:"low,omitempty"`
	High []byte `protobuf:"bytes,2,opt,name=high,proto3" json:"high,omitempty"`
	// contains filtered or unexported fields
}

A Range is logically a set that contains all values numerically between 'low' and 'high' inclusively.

func (*FieldMatch_Range) Descriptor deprecated 

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

Deprecated: Use FieldMatch_Range.ProtoReflect.Descriptor instead.

func (*FieldMatch_Range) GetHigh 

func (x *FieldMatch_Range) GetHigh() []byte

func (*FieldMatch_Range) GetLow 

func (x *FieldMatch_Range) GetLow() []byte

func (*FieldMatch_Range) ProtoMessage 

func (*FieldMatch_Range) ProtoMessage()

func (*FieldMatch_Range) ProtoReflect added in v1.4.0 

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

func (*FieldMatch_Range) Reset 

func (x *FieldMatch_Range) Reset()

func (*FieldMatch_Range) String 

func (x *FieldMatch_Range) String() string

type FieldMatch_Range_ 

type FieldMatch_Range_ struct {
	Range *FieldMatch_Range `protobuf:"bytes,6,opt,name=range,proto3,oneof"`
}

type FieldMatch_Ternary 

type FieldMatch_Ternary struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Mask  []byte `protobuf:"bytes,2,opt,name=mask,proto3" json:"mask,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldMatch_Ternary) Descriptor deprecated 

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

Deprecated: Use FieldMatch_Ternary.ProtoReflect.Descriptor instead.

func (*FieldMatch_Ternary) GetMask 

func (x *FieldMatch_Ternary) GetMask() []byte

func (*FieldMatch_Ternary) GetValue 

func (x *FieldMatch_Ternary) GetValue() []byte

func (*FieldMatch_Ternary) ProtoMessage 

func (*FieldMatch_Ternary) ProtoMessage()

func (*FieldMatch_Ternary) ProtoReflect added in v1.4.0 

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

func (*FieldMatch_Ternary) Reset 

func (x *FieldMatch_Ternary) Reset()

func (*FieldMatch_Ternary) String 

func (x *FieldMatch_Ternary) String() string

type FieldMatch_Ternary_ 

type FieldMatch_Ternary_ struct {
	Ternary *FieldMatch_Ternary `protobuf:"bytes,3,opt,name=ternary,proto3,oneof"`
}

type ForwardingPipelineConfig 

type ForwardingPipelineConfig struct {
	P4Info *v1.P4Info `protobuf:"bytes,1,opt,name=p4info,proto3" json:"p4info,omitempty"`
	// Target-specific P4 configuration.
	P4DeviceConfig []byte                           `protobuf:"bytes,2,opt,name=p4_device_config,json=p4DeviceConfig,proto3" json:"p4_device_config,omitempty"`
	Cookie         *ForwardingPipelineConfig_Cookie `protobuf:"bytes,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardingPipelineConfig) Descriptor deprecated 

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

Deprecated: Use ForwardingPipelineConfig.ProtoReflect.Descriptor instead.

func (*ForwardingPipelineConfig) GetCookie 

func (x *ForwardingPipelineConfig) GetCookie() *ForwardingPipelineConfig_Cookie

func (*ForwardingPipelineConfig) GetP4DeviceConfig 

func (x *ForwardingPipelineConfig) GetP4DeviceConfig() []byte

func (*ForwardingPipelineConfig) GetP4Info 

func (x *ForwardingPipelineConfig) GetP4Info() *v1.P4Info

func (*ForwardingPipelineConfig) ProtoMessage 

func (*ForwardingPipelineConfig) ProtoMessage()

func (*ForwardingPipelineConfig) ProtoReflect added in v1.4.0 

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

func (*ForwardingPipelineConfig) Reset 

func (x *ForwardingPipelineConfig) Reset()

func (*ForwardingPipelineConfig) String 

func (x *ForwardingPipelineConfig) String() string
type ForwardingPipelineConfig_Cookie struct {
	Cookie uint64 `protobuf:"varint,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

Metadata (cookie) opaque to the target. A control plane may use this field to uniquely identify this config. There are no restrictions on how such value is computed, or where this is stored on the target, as long as it is returned with a GetForwardingPipelineConfig RPC. When reading the cookie, we need to distinguish those cases where a cookie is NOT present (e.g. not set in the SetForwardingPipelineConfigRequest, therefore we wrap the actual uint64 value in a protobuf message.

func (*ForwardingPipelineConfig_Cookie) Descriptor deprecated 

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

Deprecated: Use ForwardingPipelineConfig_Cookie.ProtoReflect.Descriptor instead.

func (*ForwardingPipelineConfig_Cookie) GetCookie 

func (x *ForwardingPipelineConfig_Cookie) GetCookie() uint64

func (*ForwardingPipelineConfig_Cookie) ProtoMessage 

func (*ForwardingPipelineConfig_Cookie) ProtoMessage()

func (*ForwardingPipelineConfig_Cookie) ProtoReflect added in v1.4.0 

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

func (*ForwardingPipelineConfig_Cookie) Reset 

func (x *ForwardingPipelineConfig_Cookie) Reset()

func (*ForwardingPipelineConfig_Cookie) String 

func (x *ForwardingPipelineConfig_Cookie) String() string

type GetForwardingPipelineConfigRequest 

type GetForwardingPipelineConfigRequest struct {
	DeviceId     uint64                                          `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	ResponseType GetForwardingPipelineConfigRequest_ResponseType `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetForwardingPipelineConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetForwardingPipelineConfigRequest.ProtoReflect.Descriptor instead.

func (*GetForwardingPipelineConfigRequest) GetDeviceId 

func (x *GetForwardingPipelineConfigRequest) GetDeviceId() uint64

func (*GetForwardingPipelineConfigRequest) GetResponseType 

func (x *GetForwardingPipelineConfigRequest) GetResponseType() GetForwardingPipelineConfigRequest_ResponseType

func (*GetForwardingPipelineConfigRequest) ProtoMessage 

func (*GetForwardingPipelineConfigRequest) ProtoMessage()

func (*GetForwardingPipelineConfigRequest) ProtoReflect added in v1.4.0 

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

func (*GetForwardingPipelineConfigRequest) Reset 

func (x *GetForwardingPipelineConfigRequest) Reset()

func (*GetForwardingPipelineConfigRequest) String 

func (x *GetForwardingPipelineConfigRequest) String() string

type GetForwardingPipelineConfigRequest_ResponseType 

type GetForwardingPipelineConfigRequest_ResponseType int32

Specifies the fields to populate in the response. 

const (
	// Default behaviour. Returns a ForwardingPipelineConfig with all fields set
	// as stored by the target.
	GetForwardingPipelineConfigRequest_ALL GetForwardingPipelineConfigRequest_ResponseType = 0
	// Reply by setting only the cookie field, omitting all other fields.
	GetForwardingPipelineConfigRequest_COOKIE_ONLY GetForwardingPipelineConfigRequest_ResponseType = 1
	// Reply by setting the p4info and cookie fields.
	GetForwardingPipelineConfigRequest_P4INFO_AND_COOKIE GetForwardingPipelineConfigRequest_ResponseType = 2
	// Reply by setting the p4_device_config and cookie fields.
	GetForwardingPipelineConfigRequest_DEVICE_CONFIG_AND_COOKIE GetForwardingPipelineConfigRequest_ResponseType = 3
)

func (GetForwardingPipelineConfigRequest_ResponseType) Descriptor added in v1.4.0 

func (GetForwardingPipelineConfigRequest_ResponseType) Descriptor() protoreflect.EnumDescriptor

func (GetForwardingPipelineConfigRequest_ResponseType) Enum added in v1.4.0 

func (x GetForwardingPipelineConfigRequest_ResponseType) Enum() *GetForwardingPipelineConfigRequest_ResponseType

func (GetForwardingPipelineConfigRequest_ResponseType) EnumDescriptor deprecated 

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

Deprecated: Use GetForwardingPipelineConfigRequest_ResponseType.Descriptor instead.

func (GetForwardingPipelineConfigRequest_ResponseType) Number added in v1.4.0 

func (x GetForwardingPipelineConfigRequest_ResponseType) Number() protoreflect.EnumNumber

func (GetForwardingPipelineConfigRequest_ResponseType) String 

func (x GetForwardingPipelineConfigRequest_ResponseType) String() string

func (GetForwardingPipelineConfigRequest_ResponseType) Type added in v1.4.0 

func (GetForwardingPipelineConfigRequest_ResponseType) Type() protoreflect.EnumType

type GetForwardingPipelineConfigResponse 

type GetForwardingPipelineConfigResponse struct {
	Config *ForwardingPipelineConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetForwardingPipelineConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetForwardingPipelineConfigResponse.ProtoReflect.Descriptor instead.

func (*GetForwardingPipelineConfigResponse) GetConfig 

func (x *GetForwardingPipelineConfigResponse) GetConfig() *ForwardingPipelineConfig

func (*GetForwardingPipelineConfigResponse) ProtoMessage 

func (*GetForwardingPipelineConfigResponse) ProtoMessage()

func (*GetForwardingPipelineConfigResponse) ProtoReflect added in v1.4.0 

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

func (*GetForwardingPipelineConfigResponse) Reset 

func (x *GetForwardingPipelineConfigResponse) Reset()

func (*GetForwardingPipelineConfigResponse) String 

func (x *GetForwardingPipelineConfigResponse) String() string

type IdleTimeoutNotification 

type IdleTimeoutNotification struct {

	// The only fields that are required to be set in each TableEntry are the
	// "key" fields (table_id, match and priority) along with controller_metadata,
	// metadata and idle_timeout_ns.
	TableEntry []*TableEntry `protobuf:"bytes,1,rep,name=table_entry,json=tableEntry,proto3" json:"table_entry,omitempty"`
	// Timestamp at which the server generated the message (in nanoseconds since
	// Epoch)
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*IdleTimeoutNotification) Descriptor deprecated 

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

Deprecated: Use IdleTimeoutNotification.ProtoReflect.Descriptor instead.

func (*IdleTimeoutNotification) GetTableEntry 

func (x *IdleTimeoutNotification) GetTableEntry() []*TableEntry

func (*IdleTimeoutNotification) GetTimestamp 

func (x *IdleTimeoutNotification) GetTimestamp() int64

func (*IdleTimeoutNotification) ProtoMessage 

func (*IdleTimeoutNotification) ProtoMessage()

func (*IdleTimeoutNotification) ProtoReflect added in v1.4.0 

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

func (*IdleTimeoutNotification) Reset 

func (x *IdleTimeoutNotification) Reset()

func (*IdleTimeoutNotification) String 

func (x *IdleTimeoutNotification) String() string

type Index 

type Index struct {
	Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

An index as a protobuf message. In proto3, fields cannot be optional and there is no difference between an unset integer field and an integer field set to 0. This is inconvenient for reading from P4 array-like structures, such as indirect counters and meters. We need a way to do a wildcard read on these but we cannot use a default zero index value to do so, as zero is a valid index (first entry in the array). We therefore wrap the index in a message.

func (*Index) Descriptor deprecated 

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

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetIndex 

func (x *Index) GetIndex() int64

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect added in v1.4.0 

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

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

type MasterArbitrationUpdate 

type MasterArbitrationUpdate struct {
	DeviceId uint64 `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// The role for which the primary client is being arbitrated. For use-cases
	// where multiple roles are not needed, the controller can leave this unset,
	// implying default role and full pipeline access.
	Role *Role `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// The stream RPC with the highest election_id is the primary. The 'primary'
	// controller instance populates this with its latest election_id. Switch
	// populates with the highest election ID it has received from all connected
	// controllers.
	ElectionId *Uint128 `protobuf:"bytes,3,opt,name=election_id,json=electionId,proto3" json:"election_id,omitempty"`
	// Switch populates this with OK for the client that is the primary, and
	// with an error status for all other connected clients (at every primary
	// client change). The controller does not populate this field.
	Status *status.Status `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterArbitrationUpdate) Descriptor deprecated 

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

Deprecated: Use MasterArbitrationUpdate.ProtoReflect.Descriptor instead.

func (*MasterArbitrationUpdate) GetDeviceId 

func (x *MasterArbitrationUpdate) GetDeviceId() uint64

func (*MasterArbitrationUpdate) GetElectionId 

func (x *MasterArbitrationUpdate) GetElectionId() *Uint128

func (*MasterArbitrationUpdate) GetRole 

func (x *MasterArbitrationUpdate) GetRole() *Role

func (*MasterArbitrationUpdate) GetStatus 

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

func (*MasterArbitrationUpdate) ProtoMessage 

func (*MasterArbitrationUpdate) ProtoMessage()

func (*MasterArbitrationUpdate) ProtoReflect added in v1.4.0 

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

func (*MasterArbitrationUpdate) Reset 

func (x *MasterArbitrationUpdate) Reset()

func (*MasterArbitrationUpdate) String 

func (x *MasterArbitrationUpdate) String() string

type MeterConfig 

type MeterConfig struct {

	// Committed information rate (units per sec)
	Cir int64 `protobuf:"varint,1,opt,name=cir,proto3" json:"cir,omitempty"`
	// Committed burst size
	Cburst int64 `protobuf:"varint,2,opt,name=cburst,proto3" json:"cburst,omitempty"`
	// Peak information rate (units per sec)
	Pir int64 `protobuf:"varint,3,opt,name=pir,proto3" json:"pir,omitempty"`
	// Peak burst size
	Pburst int64 `protobuf:"varint,4,opt,name=pburst,proto3" json:"pburst,omitempty"`
	// Excess burst size (only used by srTCM).
	// Added in 1.4.0.
	Eburst int64 `protobuf:"varint,5,opt,name=eburst,proto3" json:"eburst,omitempty"`
	// contains filtered or unexported fields
}

Modeled to support both RFC 2698: A Two Rate Three Color Marker (trTCM) and RFC 2697: A Single Rate Three Color Marker (srTCM) based on the `type` of the corresponding MeterSpec.

The trTCM meters a packet stream and marks its packets based on two rates, Peak Information Rate (PIR) and Committed Information Rate (CIR), and their associated burst sizes to be either green, yellow, or red. A packet is marked red if it exceeds the PIR. Otherwise it is marked either yellow or green depending on whether it exceeds or doesn't exceed the CIR. For this meter type, `eburst` must be unset.

The srTCM meters a packet stream and marks its packets based on one rate, Committed Information Rate (CIR), and its associated burst size as well as an Excess Burst Size (EBS) to be either green, yellow, or red. Roughly, a packet is marked green if it doesn't exceed the CIR. Otherwise it is marked either yellow or green depending on whether it exceeds or doesn't exceed the EBS. For this meter type, it must be the case that `cir == pir && cburst == pburst`.

func (*MeterConfig) Descriptor deprecated 

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

Deprecated: Use MeterConfig.ProtoReflect.Descriptor instead.

func (*MeterConfig) GetCburst 

func (x *MeterConfig) GetCburst() int64

func (*MeterConfig) GetCir 

func (x *MeterConfig) GetCir() int64

func (*MeterConfig) GetEburst added in v1.4.0 

func (x *MeterConfig) GetEburst() int64

func (*MeterConfig) GetPburst 

func (x *MeterConfig) GetPburst() int64

func (*MeterConfig) GetPir 

func (x *MeterConfig) GetPir() int64

func (*MeterConfig) ProtoMessage 

func (*MeterConfig) ProtoMessage()

func (*MeterConfig) ProtoReflect added in v1.4.0 

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

func (*MeterConfig) Reset 

func (x *MeterConfig) Reset()

func (*MeterConfig) String 

func (x *MeterConfig) String() string

type MeterCounterData added in v1.4.0 

type MeterCounterData struct {
	Green  *CounterData `protobuf:"bytes,1,opt,name=green,proto3" json:"green,omitempty"`
	Yellow *CounterData `protobuf:"bytes,2,opt,name=yellow,proto3" json:"yellow,omitempty"`
	Red    *CounterData `protobuf:"bytes,3,opt,name=red,proto3" json:"red,omitempty"`
	// contains filtered or unexported fields
}

Added in v1.4.0

func (*MeterCounterData) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use MeterCounterData.ProtoReflect.Descriptor instead.

func (*MeterCounterData) GetGreen added in v1.4.0 

func (x *MeterCounterData) GetGreen() *CounterData

func (*MeterCounterData) GetRed added in v1.4.0 

func (x *MeterCounterData) GetRed() *CounterData

func (*MeterCounterData) GetYellow added in v1.4.0 

func (x *MeterCounterData) GetYellow() *CounterData

func (*MeterCounterData) ProtoMessage added in v1.4.0 

func (*MeterCounterData) ProtoMessage()

func (*MeterCounterData) ProtoReflect added in v1.4.0 

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

func (*MeterCounterData) Reset added in v1.4.0 

func (x *MeterCounterData) Reset()

func (*MeterCounterData) String added in v1.4.0 

func (x *MeterCounterData) String() string

type MeterEntry 

type MeterEntry struct {
	MeterId uint32       `protobuf:"varint,1,opt,name=meter_id,json=meterId,proto3" json:"meter_id,omitempty"`
	Index   *Index       `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	Config  *MeterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// Added in v1.4.0
	CounterData *MeterCounterData `protobuf:"bytes,4,opt,name=counter_data,json=counterData,proto3" json:"counter_data,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ For WriteRequest, Update.Type must be MODIFY. For ReadRequest, the scope is defined as follows: - All meter cells for all meters if meter_id = 0 (default). - All meter cells for given meter_id if index is unset (default).

func (*MeterEntry) Descriptor deprecated 

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

Deprecated: Use MeterEntry.ProtoReflect.Descriptor instead.

func (*MeterEntry) GetConfig 

func (x *MeterEntry) GetConfig() *MeterConfig

func (*MeterEntry) GetCounterData added in v1.4.0 

func (x *MeterEntry) GetCounterData() *MeterCounterData

func (*MeterEntry) GetIndex 

func (x *MeterEntry) GetIndex() *Index

func (*MeterEntry) GetMeterId 

func (x *MeterEntry) GetMeterId() uint32

func (*MeterEntry) ProtoMessage 

func (*MeterEntry) ProtoMessage()

func (*MeterEntry) ProtoReflect added in v1.4.0 

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

func (*MeterEntry) Reset 

func (x *MeterEntry) Reset()

func (*MeterEntry) String 

func (x *MeterEntry) String() string

type MulticastGroupEntry 

type MulticastGroupEntry struct {
	MulticastGroupId uint32     `protobuf:"varint,1,opt,name=multicast_group_id,json=multicastGroupId,proto3" json:"multicast_group_id,omitempty"`
	Replicas         []*Replica `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// Arbitrary metadata from the controller that is opaque to the target.
	// Added in 1.4.0.
	Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

The (port, instance) pair must be unique for each replica in a given multicast group entry. A packet may be multicast by setting the multicast_group field of PSA ingress output metadata to multicast_group_id of a programmed multicast group entry. The port and instance fields of each replica's egress input metadata will be set to the respective values programmed in the multicast group entry.

func (*MulticastGroupEntry) Descriptor deprecated 

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

Deprecated: Use MulticastGroupEntry.ProtoReflect.Descriptor instead.

func (*MulticastGroupEntry) GetMetadata added in v1.4.0 

func (x *MulticastGroupEntry) GetMetadata() []byte

func (*MulticastGroupEntry) GetMulticastGroupId 

func (x *MulticastGroupEntry) GetMulticastGroupId() uint32

func (*MulticastGroupEntry) GetReplicas 

func (x *MulticastGroupEntry) GetReplicas() []*Replica

func (*MulticastGroupEntry) ProtoMessage 

func (*MulticastGroupEntry) ProtoMessage()

func (*MulticastGroupEntry) ProtoReflect added in v1.4.0 

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

func (*MulticastGroupEntry) Reset 

func (x *MulticastGroupEntry) Reset()

func (*MulticastGroupEntry) String 

func (x *MulticastGroupEntry) String() string

type P4Data 

type P4Data struct {

	// Types that are assignable to Data:
	//
	//	*P4Data_Bitstring
	//	*P4Data_Varbit
	//	*P4Data_Bool
	//	*P4Data_Tuple
	//	*P4Data_Struct
	//	*P4Data_Header
	//	*P4Data_HeaderUnion
	//	*P4Data_HeaderStack
	//	*P4Data_HeaderUnionStack
	//	*P4Data_Enum
	//	*P4Data_Error
	//	*P4Data_EnumValue
	Data isP4Data_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*P4Data) Descriptor deprecated 

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

Deprecated: Use P4Data.ProtoReflect.Descriptor instead.

func (*P4Data) GetBitstring 

func (x *P4Data) GetBitstring() []byte

func (*P4Data) GetBool 

func (x *P4Data) GetBool() bool

func (*P4Data) GetData 

func (m *P4Data) GetData() isP4Data_Data

func (*P4Data) GetEnum 

func (x *P4Data) GetEnum() string

func (*P4Data) GetEnumValue 

func (x *P4Data) GetEnumValue() []byte

func (*P4Data) GetError 

func (x *P4Data) GetError() string

func (*P4Data) GetHeader 

func (x *P4Data) GetHeader() *P4Header

func (*P4Data) GetHeaderStack 

func (x *P4Data) GetHeaderStack() *P4HeaderStack

func (*P4Data) GetHeaderUnion 

func (x *P4Data) GetHeaderUnion() *P4HeaderUnion

func (*P4Data) GetHeaderUnionStack 

func (x *P4Data) GetHeaderUnionStack() *P4HeaderUnionStack

func (*P4Data) GetStruct 

func (x *P4Data) GetStruct() *P4StructLike

func (*P4Data) GetTuple 

func (x *P4Data) GetTuple() *P4StructLike

func (*P4Data) GetVarbit 

func (x *P4Data) GetVarbit() *P4Varbit

func (*P4Data) ProtoMessage 

func (*P4Data) ProtoMessage()

func (*P4Data) ProtoReflect added in v1.4.0 

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

func (*P4Data) Reset 

func (x *P4Data) Reset()

func (*P4Data) String 

func (x *P4Data) String() string

type P4Data_Bitstring 

type P4Data_Bitstring struct {
	Bitstring []byte `protobuf:"bytes,1,opt,name=bitstring,proto3,oneof"` // for bit<W>, int<W>
}

type P4Data_Bool 

type P4Data_Bool struct {
	Bool bool `protobuf:"varint,3,opt,name=bool,proto3,oneof"`
}

type P4Data_Enum 

type P4Data_Enum struct {
	Enum string `protobuf:"bytes,10,opt,name=enum,proto3,oneof"` // safe (non-serializable) enums only
}

type P4Data_EnumValue 

type P4Data_EnumValue struct {
	EnumValue []byte `protobuf:"bytes,12,opt,name=enum_value,json=enumValue,proto3,oneof"` // serializable enums only
}

type P4Data_Error 

type P4Data_Error struct {
	Error string `protobuf:"bytes,11,opt,name=error,proto3,oneof"`
}

type P4Data_Header 

type P4Data_Header struct {
	Header *P4Header `protobuf:"bytes,6,opt,name=header,proto3,oneof"`
}

type P4Data_HeaderStack 

type P4Data_HeaderStack struct {
	HeaderStack *P4HeaderStack `protobuf:"bytes,8,opt,name=header_stack,json=headerStack,proto3,oneof"`
}

type P4Data_HeaderUnion 

type P4Data_HeaderUnion struct {
	HeaderUnion *P4HeaderUnion `protobuf:"bytes,7,opt,name=header_union,json=headerUnion,proto3,oneof"`
}

type P4Data_HeaderUnionStack 

type P4Data_HeaderUnionStack struct {
	HeaderUnionStack *P4HeaderUnionStack `protobuf:"bytes,9,opt,name=header_union_stack,json=headerUnionStack,proto3,oneof"`
}

type P4Data_Struct 

type P4Data_Struct struct {
	Struct *P4StructLike `protobuf:"bytes,5,opt,name=struct,proto3,oneof"`
}

type P4Data_Tuple 

type P4Data_Tuple struct {
	Tuple *P4StructLike `protobuf:"bytes,4,opt,name=tuple,proto3,oneof"`
}

type P4Data_Varbit 

type P4Data_Varbit struct {
	Varbit *P4Varbit `protobuf:"bytes,2,opt,name=varbit,proto3,oneof"` // for varbit<W>
}

type P4Header 

type P4Header struct {

	// If the header is invalid (is_valid is "false"), then the bitstrings
	// repeated field must be empty.
	IsValid    bool     `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"`
	Bitstrings [][]byte `protobuf:"bytes,2,rep,name=bitstrings,proto3" json:"bitstrings,omitempty"`
	// contains filtered or unexported fields
}

func (*P4Header) Descriptor deprecated 

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

Deprecated: Use P4Header.ProtoReflect.Descriptor instead.

func (*P4Header) GetBitstrings 

func (x *P4Header) GetBitstrings() [][]byte

func (*P4Header) GetIsValid 

func (x *P4Header) GetIsValid() bool

func (*P4Header) ProtoMessage 

func (*P4Header) ProtoMessage()

func (*P4Header) ProtoReflect added in v1.4.0 

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

func (*P4Header) Reset 

func (x *P4Header) Reset()

func (*P4Header) String 

func (x *P4Header) String() string

type P4HeaderStack 

type P4HeaderStack struct {

	// The length of this repeated field must always be equal to the compile-time
	// size of the header stack, which is specified in P4Info.
	Entries []*P4Header `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*P4HeaderStack) Descriptor deprecated 

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

Deprecated: Use P4HeaderStack.ProtoReflect.Descriptor instead.

func (*P4HeaderStack) GetEntries 

func (x *P4HeaderStack) GetEntries() []*P4Header

func (*P4HeaderStack) ProtoMessage 

func (*P4HeaderStack) ProtoMessage()

func (*P4HeaderStack) ProtoReflect added in v1.4.0 

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

func (*P4HeaderStack) Reset 

func (x *P4HeaderStack) Reset()

func (*P4HeaderStack) String 

func (x *P4HeaderStack) String() string

type P4HeaderUnion 

type P4HeaderUnion struct {

	// An empty string indicates that none of the union members are valid and
	// valid_header must therefore be unset.
	ValidHeaderName string    `protobuf:"bytes,1,opt,name=valid_header_name,json=validHeaderName,proto3" json:"valid_header_name,omitempty"`
	ValidHeader     *P4Header `protobuf:"bytes,2,opt,name=valid_header,json=validHeader,proto3" json:"valid_header,omitempty"`
	// contains filtered or unexported fields
}

func (*P4HeaderUnion) Descriptor deprecated 

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

Deprecated: Use P4HeaderUnion.ProtoReflect.Descriptor instead.

func (*P4HeaderUnion) GetValidHeader 

func (x *P4HeaderUnion) GetValidHeader() *P4Header

func (*P4HeaderUnion) GetValidHeaderName 

func (x *P4HeaderUnion) GetValidHeaderName() string

func (*P4HeaderUnion) ProtoMessage 

func (*P4HeaderUnion) ProtoMessage()

func (*P4HeaderUnion) ProtoReflect added in v1.4.0 

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

func (*P4HeaderUnion) Reset 

func (x *P4HeaderUnion) Reset()

func (*P4HeaderUnion) String 

func (x *P4HeaderUnion) String() string

type P4HeaderUnionStack 

type P4HeaderUnionStack struct {

	// The length of this repeated field must always be equal to the compile-time
	// size of the header union stack, which is specified in P4Info.
	Entries []*P4HeaderUnion `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*P4HeaderUnionStack) Descriptor deprecated 

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

Deprecated: Use P4HeaderUnionStack.ProtoReflect.Descriptor instead.

func (*P4HeaderUnionStack) GetEntries 

func (x *P4HeaderUnionStack) GetEntries() []*P4HeaderUnion

func (*P4HeaderUnionStack) ProtoMessage 

func (*P4HeaderUnionStack) ProtoMessage()

func (*P4HeaderUnionStack) ProtoReflect added in v1.4.0 

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

func (*P4HeaderUnionStack) Reset 

func (x *P4HeaderUnionStack) Reset()

func (*P4HeaderUnionStack) String 

func (x *P4HeaderUnionStack) String() string

type P4RuntimeClient 

type P4RuntimeClient interface {
	// Update one or more P4 entities on the target.
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	// Read one or more P4 entities from the target.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (P4Runtime_ReadClient, error)
	// Sets the P4 forwarding-pipeline config.
	SetForwardingPipelineConfig(ctx context.Context, in *SetForwardingPipelineConfigRequest, opts ...grpc.CallOption) (*SetForwardingPipelineConfigResponse, error)
	// Gets the current P4 forwarding-pipeline config.
	GetForwardingPipelineConfig(ctx context.Context, in *GetForwardingPipelineConfigRequest, opts ...grpc.CallOption) (*GetForwardingPipelineConfigResponse, error)
	// Represents the bidirectional stream between the controller and the
	// switch (initiated by the controller), and is managed for the following
	// purposes:
	//   - connection initiation through client arbitration
	//   - indicating switch session liveness: the session is live when switch
	//     sends a positive client arbitration update to the controller, and is
	//     considered dead when either the stream breaks or the switch sends a
	//     negative update for client arbitration
	//   - the controller sending/receiving packets to/from the switch
	//   - streaming of notifications from the switch
	StreamChannel(ctx context.Context, opts ...grpc.CallOption) (P4Runtime_StreamChannelClient, error)
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
}

P4RuntimeClient is the client API for P4Runtime 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.

func NewP4RuntimeClient 

func NewP4RuntimeClient(cc grpc.ClientConnInterface) P4RuntimeClient

type P4RuntimeServer 

type P4RuntimeServer interface {
	// Update one or more P4 entities on the target.
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// Read one or more P4 entities from the target.
	Read(*ReadRequest, P4Runtime_ReadServer) error
	// Sets the P4 forwarding-pipeline config.
	SetForwardingPipelineConfig(context.Context, *SetForwardingPipelineConfigRequest) (*SetForwardingPipelineConfigResponse, error)
	// Gets the current P4 forwarding-pipeline config.
	GetForwardingPipelineConfig(context.Context, *GetForwardingPipelineConfigRequest) (*GetForwardingPipelineConfigResponse, error)
	// Represents the bidirectional stream between the controller and the
	// switch (initiated by the controller), and is managed for the following
	// purposes:
	//   - connection initiation through client arbitration
	//   - indicating switch session liveness: the session is live when switch
	//     sends a positive client arbitration update to the controller, and is
	//     considered dead when either the stream breaks or the switch sends a
	//     negative update for client arbitration
	//   - the controller sending/receiving packets to/from the switch
	//   - streaming of notifications from the switch
	StreamChannel(P4Runtime_StreamChannelServer) error
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
	// contains filtered or unexported methods
}

P4RuntimeServer is the server API for P4Runtime service. All implementations must embed UnimplementedP4RuntimeServer for forward compatibility

type P4Runtime_ReadClient 

type P4Runtime_ReadClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type P4Runtime_ReadServer 

type P4Runtime_ReadServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type P4Runtime_StreamChannelClient 

type P4Runtime_StreamChannelClient interface {
	Send(*StreamMessageRequest) error
	Recv() (*StreamMessageResponse, error)
	grpc.ClientStream
}

type P4Runtime_StreamChannelServer 

type P4Runtime_StreamChannelServer interface {
	Send(*StreamMessageResponse) error
	Recv() (*StreamMessageRequest, error)
	grpc.ServerStream
}

type P4StructLike 

type P4StructLike struct {
	Members []*P4Data `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*P4StructLike) Descriptor deprecated 

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

Deprecated: Use P4StructLike.ProtoReflect.Descriptor instead.

func (*P4StructLike) GetMembers 

func (x *P4StructLike) GetMembers() []*P4Data

func (*P4StructLike) ProtoMessage 

func (*P4StructLike) ProtoMessage()

func (*P4StructLike) ProtoReflect added in v1.4.0 

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

func (*P4StructLike) Reset 

func (x *P4StructLike) Reset()

func (*P4StructLike) String 

func (x *P4StructLike) String() string

type P4Varbit 

type P4Varbit struct {
	Bitstring []byte `protobuf:"bytes,1,opt,name=bitstring,proto3" json:"bitstring,omitempty"`
	Bitwidth  int32  `protobuf:"varint,2,opt,name=bitwidth,proto3" json:"bitwidth,omitempty"` // dynamic bitwidth of the field
	// contains filtered or unexported fields
}

func (*P4Varbit) Descriptor deprecated 

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

Deprecated: Use P4Varbit.ProtoReflect.Descriptor instead.

func (*P4Varbit) GetBitstring 

func (x *P4Varbit) GetBitstring() []byte

func (*P4Varbit) GetBitwidth 

func (x *P4Varbit) GetBitwidth() int32

func (*P4Varbit) ProtoMessage 

func (*P4Varbit) ProtoMessage()

func (*P4Varbit) ProtoReflect added in v1.4.0 

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

func (*P4Varbit) Reset 

func (x *P4Varbit) Reset()

func (*P4Varbit) String 

func (x *P4Varbit) String() string

type PacketIn 

type PacketIn struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// This will be based on P4 header annotated as
	// @controller_header("packet_in").
	// At most one P4 header can have this annotation.
	Metadata []*PacketMetadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Packet sent from the switch to the controller.

func (*PacketIn) Descriptor deprecated 

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

Deprecated: Use PacketIn.ProtoReflect.Descriptor instead.

func (*PacketIn) GetMetadata 

func (x *PacketIn) GetMetadata() []*PacketMetadata

func (*PacketIn) GetPayload 

func (x *PacketIn) GetPayload() []byte

func (*PacketIn) ProtoMessage 

func (*PacketIn) ProtoMessage()

func (*PacketIn) ProtoReflect added in v1.4.0 

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

func (*PacketIn) Reset 

func (x *PacketIn) Reset()

func (*PacketIn) String 

func (x *PacketIn) String() string

type PacketMetadata 

type PacketMetadata struct {

	// This refers to Metadata.id coming from P4Info ControllerPacketMetadata.
	MetadataId uint32 `protobuf:"varint,1,opt,name=metadata_id,json=metadataId,proto3" json:"metadata_id,omitempty"`
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Any metadata associated with Packet-IO (controller Packet-In or Packet-Out) needs to be modeled as P4 headers carrying special annotations @controller_header("packet_out") and @controller_header("packet_in") respectively. There can be at most one header each with these annotations. These special headers are captured in P4Info ControllerPacketMetadata.

func (*PacketMetadata) Descriptor deprecated 

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

Deprecated: Use PacketMetadata.ProtoReflect.Descriptor instead.

func (*PacketMetadata) GetMetadataId 

func (x *PacketMetadata) GetMetadataId() uint32

func (*PacketMetadata) GetValue 

func (x *PacketMetadata) GetValue() []byte

func (*PacketMetadata) ProtoMessage 

func (*PacketMetadata) ProtoMessage()

func (*PacketMetadata) ProtoReflect added in v1.4.0 

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

func (*PacketMetadata) Reset 

func (x *PacketMetadata) Reset()

func (*PacketMetadata) String 

func (x *PacketMetadata) String() string

type PacketOut 

type PacketOut struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// This will be based on P4 header annotated as
	// @controller_header("packet_out").
	// At most one P4 header can have this annotation.
	Metadata []*PacketMetadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Packet sent from the controller to the switch.

func (*PacketOut) Descriptor deprecated 

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

Deprecated: Use PacketOut.ProtoReflect.Descriptor instead.

func (*PacketOut) GetMetadata 

func (x *PacketOut) GetMetadata() []*PacketMetadata

func (*PacketOut) GetPayload 

func (x *PacketOut) GetPayload() []byte

func (*PacketOut) ProtoMessage 

func (*PacketOut) ProtoMessage()

func (*PacketOut) ProtoReflect added in v1.4.0 

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

func (*PacketOut) Reset 

func (x *PacketOut) Reset()

func (*PacketOut) String 

func (x *PacketOut) String() string

type PacketOutError 

type PacketOutError struct {

	// Optional. The packet out message that caused the error.
	PacketOut *PacketOut `protobuf:"bytes,1,opt,name=packet_out,json=packetOut,proto3" json:"packet_out,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketOutError) Descriptor deprecated 

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

Deprecated: Use PacketOutError.ProtoReflect.Descriptor instead.

func (*PacketOutError) GetPacketOut 

func (x *PacketOutError) GetPacketOut() *PacketOut

func (*PacketOutError) ProtoMessage 

func (*PacketOutError) ProtoMessage()

func (*PacketOutError) ProtoReflect added in v1.4.0 

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

func (*PacketOutError) Reset 

func (x *PacketOutError) Reset()

func (*PacketOutError) String 

func (x *PacketOutError) String() string

type PacketReplicationEngineEntry 

type PacketReplicationEngineEntry struct {

	// Types that are assignable to Type:
	//
	//	*PacketReplicationEngineEntry_MulticastGroupEntry
	//	*PacketReplicationEngineEntry_CloneSessionEntry
	Type isPacketReplicationEngineEntry_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ Only one instance of a Packet Replication Engine (PRE) is expected in the P4 pipeline. Hence, no instance id is needed to access the PRE.

func (*PacketReplicationEngineEntry) Descriptor deprecated 

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

Deprecated: Use PacketReplicationEngineEntry.ProtoReflect.Descriptor instead.

func (*PacketReplicationEngineEntry) GetCloneSessionEntry 

func (x *PacketReplicationEngineEntry) GetCloneSessionEntry() *CloneSessionEntry

func (*PacketReplicationEngineEntry) GetMulticastGroupEntry 

func (x *PacketReplicationEngineEntry) GetMulticastGroupEntry() *MulticastGroupEntry

func (*PacketReplicationEngineEntry) GetType 

func (m *PacketReplicationEngineEntry) GetType() isPacketReplicationEngineEntry_Type

func (*PacketReplicationEngineEntry) ProtoMessage 

func (*PacketReplicationEngineEntry) ProtoMessage()

func (*PacketReplicationEngineEntry) ProtoReflect added in v1.4.0 

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

func (*PacketReplicationEngineEntry) Reset 

func (x *PacketReplicationEngineEntry) Reset()

func (*PacketReplicationEngineEntry) String 

func (x *PacketReplicationEngineEntry) String() string

type PacketReplicationEngineEntry_CloneSessionEntry 

type PacketReplicationEngineEntry_CloneSessionEntry struct {
	CloneSessionEntry *CloneSessionEntry `protobuf:"bytes,2,opt,name=clone_session_entry,json=cloneSessionEntry,proto3,oneof"`
}

type PacketReplicationEngineEntry_MulticastGroupEntry 

type PacketReplicationEngineEntry_MulticastGroupEntry struct {
	MulticastGroupEntry *MulticastGroupEntry `protobuf:"bytes,1,opt,name=multicast_group_entry,json=multicastGroupEntry,proto3,oneof"`
}

type ReadRequest 

type ReadRequest struct {
	DeviceId uint64 `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// When specified, only return table entries for the given role.
	// Added in 1.4.0.
	Role     string    `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	Entities []*Entity `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetDeviceId 

func (x *ReadRequest) GetDeviceId() uint64

func (*ReadRequest) GetEntities 

func (x *ReadRequest) GetEntities() []*Entity

func (*ReadRequest) GetRole added in v1.4.0 

func (x *ReadRequest) GetRole() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect added in v1.4.0 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated 

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetEntities 

func (x *ReadResponse) GetEntities() []*Entity

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect added in v1.4.0 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) String 

func (x *ReadResponse) String() string

type RegisterEntry 

type RegisterEntry struct {
	RegisterId uint32  `protobuf:"varint,1,opt,name=register_id,json=registerId,proto3" json:"register_id,omitempty"`
	Index      *Index  `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	Data       *P4Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*RegisterEntry) Descriptor deprecated 

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

Deprecated: Use RegisterEntry.ProtoReflect.Descriptor instead.

func (*RegisterEntry) GetData 

func (x *RegisterEntry) GetData() *P4Data

func (*RegisterEntry) GetIndex 

func (x *RegisterEntry) GetIndex() *Index

func (*RegisterEntry) GetRegisterId 

func (x *RegisterEntry) GetRegisterId() uint32

func (*RegisterEntry) ProtoMessage 

func (*RegisterEntry) ProtoMessage()

func (*RegisterEntry) ProtoReflect added in v1.4.0 

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

func (*RegisterEntry) Reset 

func (x *RegisterEntry) Reset()

func (*RegisterEntry) String 

func (x *RegisterEntry) String() string

type Replica 

type Replica struct {

	// Types that are assignable to PortKind:
	//
	//	*Replica_EgressPort
	//	*Replica_Port
	PortKind isReplica_PortKind `protobuf_oneof:"port_kind"`
	Instance uint32             `protobuf:"varint,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

Used for replicas created for cloning and multicasting actions.

func (*Replica) Descriptor deprecated 

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

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetEgressPort deprecated 

func (x *Replica) GetEgressPort() uint32

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*Replica) GetInstance 

func (x *Replica) GetInstance() uint32

func (*Replica) GetPort added in v1.4.0 

func (x *Replica) GetPort() []byte

func (*Replica) GetPortKind added in v1.4.0 

func (m *Replica) GetPortKind() isReplica_PortKind

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect added in v1.4.0 

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

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

type Replica_EgressPort added in v1.4.0 

type Replica_EgressPort struct {
	// Using uint32 as ports is deprecated, use port field instead.
	// Deprecated in v1.4.0
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	EgressPort uint32 `protobuf:"varint,1,opt,name=egress_port,json=egressPort,proto3,oneof"`
}

type Replica_Port added in v1.4.0 

type Replica_Port struct {
	// Added in v1.4.0
	Port []byte `protobuf:"bytes,3,opt,name=port,proto3,oneof"`
}

type Role 

type Role struct {

	// Uniquely identifies this role.
	// Deprecated in 1.4.0.
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Added in 1.4.0.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Describes the role configuration, i.e. what operations, P4 entities,
	// behaviors, etc. are in the scope of a given role. If config is not set
	// (default case), it implies all P4 objects and control behaviors are in
	// scope, i.e. full pipeline access. The format of this message is
	// out-of-scope of P4Runtime.
	Config *anypb.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Role) Descriptor deprecated 

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

Deprecated: Use Role.ProtoReflect.Descriptor instead.

func (*Role) GetConfig 

func (x *Role) GetConfig() *anypb.Any

func (*Role) GetId deprecated 

func (x *Role) GetId() uint64

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*Role) GetName added in v1.4.0 

func (x *Role) GetName() string

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) ProtoReflect added in v1.4.0 

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

func (*Role) Reset 

func (x *Role) Reset()

func (*Role) String 

func (x *Role) String() string

type SdnPort 

type SdnPort int32

------------------------------------------------------------------------------ Reserved controller-specified SDN port numbers for reference. 

const (
	SdnPort_SDN_PORT_UNKNOWN SdnPort = 0
	// SDN ports are numbered starting form 1.
	SdnPort_SDN_PORT_MIN SdnPort = 1
	// 0xfffffeff: The maximum value of an SDN port (physical or logical).
	SdnPort_SDN_PORT_MAX SdnPort = -257
	// Reserved SDN port numbers (0xffffff00 - 0xffffffff)
	// 0xfffffffa: Recirculate the packet back to ingress
	SdnPort_SDN_PORT_RECIRCULATE SdnPort = -6
	// 0xfffffffd: Send to CPU
	SdnPort_SDN_PORT_CPU SdnPort = -3
)

func (SdnPort) Descriptor added in v1.4.0 

func (SdnPort) Descriptor() protoreflect.EnumDescriptor

func (SdnPort) Enum added in v1.4.0 

func (x SdnPort) Enum() *SdnPort

func (SdnPort) EnumDescriptor deprecated 

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

Deprecated: Use SdnPort.Descriptor instead.

func (SdnPort) Number added in v1.4.0 

func (x SdnPort) Number() protoreflect.EnumNumber

func (SdnPort) String 

func (x SdnPort) String() string

func (SdnPort) Type added in v1.4.0 

func (SdnPort) Type() protoreflect.EnumType

type SetForwardingPipelineConfigRequest 

type SetForwardingPipelineConfigRequest struct {
	DeviceId uint64 `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// Deprecated in 1.4.0.
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	RoleId uint64 `protobuf:"varint,2,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// Added in 1.4.0.
	Role       string                                    `protobuf:"bytes,6,opt,name=role,proto3" json:"role,omitempty"`
	ElectionId *Uint128                                  `protobuf:"bytes,3,opt,name=election_id,json=electionId,proto3" json:"election_id,omitempty"`
	Action     SetForwardingPipelineConfigRequest_Action `protobuf:"varint,4,opt,name=action,proto3,enum=p4.v1.SetForwardingPipelineConfigRequest_Action" json:"action,omitempty"`
	Config     *ForwardingPipelineConfig                 `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*SetForwardingPipelineConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetForwardingPipelineConfigRequest.ProtoReflect.Descriptor instead.

func (*SetForwardingPipelineConfigRequest) GetAction 

func (x *SetForwardingPipelineConfigRequest) GetAction() SetForwardingPipelineConfigRequest_Action

func (*SetForwardingPipelineConfigRequest) GetConfig 

func (x *SetForwardingPipelineConfigRequest) GetConfig() *ForwardingPipelineConfig

func (*SetForwardingPipelineConfigRequest) GetDeviceId 

func (x *SetForwardingPipelineConfigRequest) GetDeviceId() uint64

func (*SetForwardingPipelineConfigRequest) GetElectionId 

func (x *SetForwardingPipelineConfigRequest) GetElectionId() *Uint128

func (*SetForwardingPipelineConfigRequest) GetRole added in v1.4.0 

func (x *SetForwardingPipelineConfigRequest) GetRole() string

func (*SetForwardingPipelineConfigRequest) GetRoleId deprecated 

func (x *SetForwardingPipelineConfigRequest) GetRoleId() uint64

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*SetForwardingPipelineConfigRequest) ProtoMessage 

func (*SetForwardingPipelineConfigRequest) ProtoMessage()

func (*SetForwardingPipelineConfigRequest) ProtoReflect added in v1.4.0 

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

func (*SetForwardingPipelineConfigRequest) Reset 

func (x *SetForwardingPipelineConfigRequest) Reset()

func (*SetForwardingPipelineConfigRequest) String 

func (x *SetForwardingPipelineConfigRequest) String() string

type SetForwardingPipelineConfigRequest_Action 

type SetForwardingPipelineConfigRequest_Action int32
const (
	SetForwardingPipelineConfigRequest_UNSPECIFIED SetForwardingPipelineConfigRequest_Action = 0
	// Verify that the target can realize the given config. Do not modify the
	// forwarding state in the target. Returns error if config is not provided
	// of if the provided config cannot be realized.
	SetForwardingPipelineConfigRequest_VERIFY SetForwardingPipelineConfigRequest_Action = 1
	// Save the config if the target can realize it. Do not modify the
	// forwarding state in the target. Any subsequent read/write requests must
	// refer to fields in the new config. Returns error if config is not
	// provided of if the provided config cannot be realized.
	SetForwardingPipelineConfigRequest_VERIFY_AND_SAVE SetForwardingPipelineConfigRequest_Action = 2
	// Verify, save and realize the given config. Clear the forwarding state
	// in the target. Returns error if config is not provided of if the
	// provided config cannot be realized.
	SetForwardingPipelineConfigRequest_VERIFY_AND_COMMIT SetForwardingPipelineConfigRequest_Action = 3
	// Realize the last saved, but not yet committed, config. Update the
	// forwarding state in the target by replaying the write requests since the
	// last config was saved. Config should not be provided for this action
	// type. Returns an error if no saved config is found or if a config is
	// provided with this message.
	SetForwardingPipelineConfigRequest_COMMIT SetForwardingPipelineConfigRequest_Action = 4
	// Verify, save and realize the given config, while preserving the
	// forwarding state in the target. This is an advanced use case to enable
	// changes to the P4 forwarding pipeline configuration with minimal traffic
	// loss. P4Runtime does not impose any constraints on the duration of the
	// traffic loss. The support for this option is not expected to be uniform
	// across all P4Runtime targets. A target that does not support this option
	// may return an UNIMPLEMENTED error. For targets that support this option,
	// an INVALID_ARGUMENT error is returned if no config is provided, or if
	// the existing forwarding state cannot be preserved for the given config
	// by the target.
	SetForwardingPipelineConfigRequest_RECONCILE_AND_COMMIT SetForwardingPipelineConfigRequest_Action = 5
)

func (SetForwardingPipelineConfigRequest_Action) Descriptor added in v1.4.0 

func (SetForwardingPipelineConfigRequest_Action) Descriptor() protoreflect.EnumDescriptor

func (SetForwardingPipelineConfigRequest_Action) Enum added in v1.4.0 

func (x SetForwardingPipelineConfigRequest_Action) Enum() *SetForwardingPipelineConfigRequest_Action

func (SetForwardingPipelineConfigRequest_Action) EnumDescriptor deprecated 

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

Deprecated: Use SetForwardingPipelineConfigRequest_Action.Descriptor instead.

func (SetForwardingPipelineConfigRequest_Action) Number added in v1.4.0 

func (x SetForwardingPipelineConfigRequest_Action) Number() protoreflect.EnumNumber

func (SetForwardingPipelineConfigRequest_Action) String 

func (x SetForwardingPipelineConfigRequest_Action) String() string

func (SetForwardingPipelineConfigRequest_Action) Type added in v1.4.0 

func (SetForwardingPipelineConfigRequest_Action) Type() protoreflect.EnumType

type SetForwardingPipelineConfigResponse 

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

func (*SetForwardingPipelineConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetForwardingPipelineConfigResponse.ProtoReflect.Descriptor instead.

func (*SetForwardingPipelineConfigResponse) ProtoMessage 

func (*SetForwardingPipelineConfigResponse) ProtoMessage()

func (*SetForwardingPipelineConfigResponse) ProtoReflect added in v1.4.0 

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

func (*SetForwardingPipelineConfigResponse) Reset 

func (x *SetForwardingPipelineConfigResponse) Reset()

func (*SetForwardingPipelineConfigResponse) String 

func (x *SetForwardingPipelineConfigResponse) String() string

type StreamError 

type StreamError struct {

	// gRPC canonical error code (see
	// https://developers.google.com/maps-booking/reference/grpc-api/status_codes)
	CanonicalCode int32 `protobuf:"varint,1,opt,name=canonical_code,json=canonicalCode,proto3" json:"canonical_code,omitempty"`
	// Optional. An explanation of the error.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Optional. Target and architecture specific space to which this error
	// belongs.
	// We encourage using triplet: <target>-<arch>-<vendor>,
	// e.g."targetX-psa-vendor1" or "targetY-psa-vendor2".
	Space string `protobuf:"bytes,3,opt,name=space,proto3" json:"space,omitempty"`
	// Optional. Numeric code drawn from target-specific error space above.
	Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	// Used by the server to convey additional information about the error. One of
	// the fields must be set (so that the client can identify which type of
	// stream message triggered the error), but that field may be set to its
	// default value.
	//
	// Types that are assignable to Details:
	//
	//	*StreamError_PacketOut
	//	*StreamError_DigestListAck
	//	*StreamError_Other
	Details isStreamError_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

Used by the server to asynchronously report errors which occur when processing StreamMessageRequest messages.

func (*StreamError) Descriptor deprecated 

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

Deprecated: Use StreamError.ProtoReflect.Descriptor instead.

func (*StreamError) GetCanonicalCode 

func (x *StreamError) GetCanonicalCode() int32

func (*StreamError) GetCode 

func (x *StreamError) GetCode() int32

func (*StreamError) GetDetails 

func (m *StreamError) GetDetails() isStreamError_Details

func (*StreamError) GetDigestListAck 

func (x *StreamError) GetDigestListAck() *DigestListAckError

func (*StreamError) GetMessage 

func (x *StreamError) GetMessage() string

func (*StreamError) GetOther 

func (x *StreamError) GetOther() *StreamOtherError

func (*StreamError) GetPacketOut 

func (x *StreamError) GetPacketOut() *PacketOutError

func (*StreamError) GetSpace 

func (x *StreamError) GetSpace() string

func (*StreamError) ProtoMessage 

func (*StreamError) ProtoMessage()

func (*StreamError) ProtoReflect added in v1.4.0 

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

func (*StreamError) Reset 

func (x *StreamError) Reset()

func (*StreamError) String 

func (x *StreamError) String() string

type StreamError_DigestListAck 

type StreamError_DigestListAck struct {
	DigestListAck *DigestListAckError `protobuf:"bytes,6,opt,name=digest_list_ack,json=digestListAck,proto3,oneof"`
}

type StreamError_Other 

type StreamError_Other struct {
	Other *StreamOtherError `protobuf:"bytes,7,opt,name=other,proto3,oneof"`
}

type StreamError_PacketOut 

type StreamError_PacketOut struct {
	PacketOut *PacketOutError `protobuf:"bytes,5,opt,name=packet_out,json=packetOut,proto3,oneof"`
}

type StreamMessageRequest 

type StreamMessageRequest struct {

	// Types that are assignable to Update:
	//
	//	*StreamMessageRequest_Arbitration
	//	*StreamMessageRequest_Packet
	//	*StreamMessageRequest_DigestAck
	//	*StreamMessageRequest_Other
	Update isStreamMessageRequest_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*StreamMessageRequest) Descriptor deprecated 

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

Deprecated: Use StreamMessageRequest.ProtoReflect.Descriptor instead.

func (*StreamMessageRequest) GetArbitration 

func (x *StreamMessageRequest) GetArbitration() *MasterArbitrationUpdate

func (*StreamMessageRequest) GetDigestAck 

func (x *StreamMessageRequest) GetDigestAck() *DigestListAck

func (*StreamMessageRequest) GetOther 

func (x *StreamMessageRequest) GetOther() *anypb.Any

func (*StreamMessageRequest) GetPacket 

func (x *StreamMessageRequest) GetPacket() *PacketOut

func (*StreamMessageRequest) GetUpdate 

func (m *StreamMessageRequest) GetUpdate() isStreamMessageRequest_Update

func (*StreamMessageRequest) ProtoMessage 

func (*StreamMessageRequest) ProtoMessage()

func (*StreamMessageRequest) ProtoReflect added in v1.4.0 

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

func (*StreamMessageRequest) Reset 

func (x *StreamMessageRequest) Reset()

func (*StreamMessageRequest) String 

func (x *StreamMessageRequest) String() string

type StreamMessageRequest_Arbitration 

type StreamMessageRequest_Arbitration struct {
	Arbitration *MasterArbitrationUpdate `protobuf:"bytes,1,opt,name=arbitration,proto3,oneof"`
}

type StreamMessageRequest_DigestAck 

type StreamMessageRequest_DigestAck struct {
	DigestAck *DigestListAck `protobuf:"bytes,3,opt,name=digest_ack,json=digestAck,proto3,oneof"`
}

type StreamMessageRequest_Other 

type StreamMessageRequest_Other struct {
	Other *anypb.Any `protobuf:"bytes,4,opt,name=other,proto3,oneof"`
}

type StreamMessageRequest_Packet 

type StreamMessageRequest_Packet struct {
	Packet *PacketOut `protobuf:"bytes,2,opt,name=packet,proto3,oneof"`
}

type StreamMessageResponse 

type StreamMessageResponse struct {

	// Types that are assignable to Update:
	//
	//	*StreamMessageResponse_Arbitration
	//	*StreamMessageResponse_Packet
	//	*StreamMessageResponse_Digest
	//	*StreamMessageResponse_IdleTimeoutNotification
	//	*StreamMessageResponse_Other
	//	*StreamMessageResponse_Error
	Update isStreamMessageResponse_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

func (*StreamMessageResponse) Descriptor deprecated 

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

Deprecated: Use StreamMessageResponse.ProtoReflect.Descriptor instead.

func (*StreamMessageResponse) GetArbitration 

func (x *StreamMessageResponse) GetArbitration() *MasterArbitrationUpdate

func (*StreamMessageResponse) GetDigest 

func (x *StreamMessageResponse) GetDigest() *DigestList

func (*StreamMessageResponse) GetError 

func (x *StreamMessageResponse) GetError() *StreamError

func (*StreamMessageResponse) GetIdleTimeoutNotification 

func (x *StreamMessageResponse) GetIdleTimeoutNotification() *IdleTimeoutNotification

func (*StreamMessageResponse) GetOther 

func (x *StreamMessageResponse) GetOther() *anypb.Any

func (*StreamMessageResponse) GetPacket 

func (x *StreamMessageResponse) GetPacket() *PacketIn

func (*StreamMessageResponse) GetUpdate 

func (m *StreamMessageResponse) GetUpdate() isStreamMessageResponse_Update

func (*StreamMessageResponse) ProtoMessage 

func (*StreamMessageResponse) ProtoMessage()

func (*StreamMessageResponse) ProtoReflect added in v1.4.0 

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

func (*StreamMessageResponse) Reset 

func (x *StreamMessageResponse) Reset()

func (*StreamMessageResponse) String 

func (x *StreamMessageResponse) String() string

type StreamMessageResponse_Arbitration 

type StreamMessageResponse_Arbitration struct {
	Arbitration *MasterArbitrationUpdate `protobuf:"bytes,1,opt,name=arbitration,proto3,oneof"`
}

type StreamMessageResponse_Digest 

type StreamMessageResponse_Digest struct {
	Digest *DigestList `protobuf:"bytes,3,opt,name=digest,proto3,oneof"`
}

type StreamMessageResponse_Error 

type StreamMessageResponse_Error struct {
	// Used by the server to asynchronously report errors which occur when
	// processing StreamMessageRequest messages.
	Error *StreamError `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type StreamMessageResponse_IdleTimeoutNotification 

type StreamMessageResponse_IdleTimeoutNotification struct {
	IdleTimeoutNotification *IdleTimeoutNotification `protobuf:"bytes,4,opt,name=idle_timeout_notification,json=idleTimeoutNotification,proto3,oneof"`
}

type StreamMessageResponse_Other 

type StreamMessageResponse_Other struct {
	Other *anypb.Any `protobuf:"bytes,5,opt,name=other,proto3,oneof"`
}

type StreamMessageResponse_Packet 

type StreamMessageResponse_Packet struct {
	Packet *PacketIn `protobuf:"bytes,2,opt,name=packet,proto3,oneof"`
}

type StreamOtherError 

type StreamOtherError struct {

	// Optional. The architecture-specific stream message that caused the error.
	Other *anypb.Any `protobuf:"bytes,1,opt,name=other,proto3" json:"other,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOtherError) Descriptor deprecated 

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

Deprecated: Use StreamOtherError.ProtoReflect.Descriptor instead.

func (*StreamOtherError) GetOther 

func (x *StreamOtherError) GetOther() *anypb.Any

func (*StreamOtherError) ProtoMessage 

func (*StreamOtherError) ProtoMessage()

func (*StreamOtherError) ProtoReflect added in v1.4.0 

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

func (*StreamOtherError) Reset 

func (x *StreamOtherError) Reset()

func (*StreamOtherError) String 

func (x *StreamOtherError) String() string

type TableAction 

type TableAction struct {

	// Types that are assignable to Type:
	//
	//	*TableAction_Action
	//	*TableAction_ActionProfileMemberId
	//	*TableAction_ActionProfileGroupId
	//	*TableAction_ActionProfileActionSet
	Type isTableAction_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

table_actions ::= action_specification | action_profile_specification

func (*TableAction) Descriptor deprecated 

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

Deprecated: Use TableAction.ProtoReflect.Descriptor instead.

func (*TableAction) GetAction 

func (x *TableAction) GetAction() *Action

func (*TableAction) GetActionProfileActionSet 

func (x *TableAction) GetActionProfileActionSet() *ActionProfileActionSet

func (*TableAction) GetActionProfileGroupId 

func (x *TableAction) GetActionProfileGroupId() uint32

func (*TableAction) GetActionProfileMemberId 

func (x *TableAction) GetActionProfileMemberId() uint32

func (*TableAction) GetType 

func (m *TableAction) GetType() isTableAction_Type

func (*TableAction) ProtoMessage 

func (*TableAction) ProtoMessage()

func (*TableAction) ProtoReflect added in v1.4.0 

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

func (*TableAction) Reset 

func (x *TableAction) Reset()

func (*TableAction) String 

func (x *TableAction) String() string

type TableAction_Action 

type TableAction_Action struct {
	Action *Action `protobuf:"bytes,1,opt,name=action,proto3,oneof"`
}

type TableAction_ActionProfileActionSet 

type TableAction_ActionProfileActionSet struct {
	ActionProfileActionSet *ActionProfileActionSet `protobuf:"bytes,4,opt,name=action_profile_action_set,json=actionProfileActionSet,proto3,oneof"`
}

type TableAction_ActionProfileGroupId 

type TableAction_ActionProfileGroupId struct {
	ActionProfileGroupId uint32 `protobuf:"varint,3,opt,name=action_profile_group_id,json=actionProfileGroupId,proto3,oneof"`
}

type TableAction_ActionProfileMemberId 

type TableAction_ActionProfileMemberId struct {
	ActionProfileMemberId uint32 `protobuf:"varint,2,opt,name=action_profile_member_id,json=actionProfileMemberId,proto3,oneof"`
}

type TableEntry 

type TableEntry struct {
	TableId uint32        `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Match   []*FieldMatch `protobuf:"bytes,2,rep,name=match,proto3" json:"match,omitempty"`
	Action  *TableAction  `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	// Should only be set if the match implies a TCAM lookup, i.e. at least one of
	// the match fields is Optional, Ternary or Range.  A higher number indicates
	// higher priority.  Only a highest priority entry that matches the packet
	// must be selected.  Multiple entries in the same table with the same
	// priority value are permitted.  See Section "TableEntry" in the
	// specification for details of the behavior.
	Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// Metadata (cookie) opaque to the target. There is no requirement of where
	// this is stored, as long as it is returned with the rest of the entry in
	// a Read RPC. This is deprecated in favor of the more flexible metadata
	// field.
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	ControllerMetadata uint64 `protobuf:"varint,5,opt,name=controller_metadata,json=controllerMetadata,proto3" json:"controller_metadata,omitempty"`
	// meter_config, counter_data and meter_counter_data are convenience fields
	// that enable the controller to configure the direct resources associated
	// with the table at the same time as a match-action entry is inserted or
	// modified.
	// Table write:
	//   - If the table does not contain a direct resource, then setting the
	//     corresponding direct resource field in any table write operation will
	//     return an error.
	//   - When inserting a new table entry, leaving these fields unset means that
	//     the direct resources of this table (if any) will assume default values.
	//     For counters, the default value is 0, and for meters, the default value
	//     is always green.
	//   - When updating a table entry, leaving meter_config unset will reset the
	//     meter (if any) to its default configuration, while leaving counter_data
	//     or meter_counter_data unset means that the counter (if any) will not be
	//     updated.
	//
	// Table read:
	//   - If the table does not contain a direct resource, then the corresponding
	//     field will not be set in the read table entry.
	//   - If meter_config is unset in the request, or if the meter has a default
	//     configuration, meter_config will not be set in the response.
	//   - If counter_data or meter_counter_data is unset in the request, it will
	//     be unset in the response as well.
	MeterConfig *MeterConfig `protobuf:"bytes,6,opt,name=meter_config,json=meterConfig,proto3" json:"meter_config,omitempty"`
	CounterData *CounterData `protobuf:"bytes,7,opt,name=counter_data,json=counterData,proto3" json:"counter_data,omitempty"`
	// Per color counters for tables with a direct meter.
	// Added in v1.4.0
	MeterCounterData *MeterCounterData `protobuf:"bytes,12,opt,name=meter_counter_data,json=meterCounterData,proto3" json:"meter_counter_data,omitempty"`
	// Set to true if the table entry is being used to update the non-const
	// default action of the table. If true, the "match" field must be empty and
	// the "action" field must be populated with a valid direct action.
	IsDefaultAction bool `protobuf:"varint,8,opt,name=is_default_action,json=isDefaultAction,proto3" json:"is_default_action,omitempty"`
	// The TTL for the entry, in nanoseconds. A value of 0 means that the table
	// entry never "expires".
	IdleTimeoutNs int64 `protobuf:"varint,9,opt,name=idle_timeout_ns,json=idleTimeoutNs,proto3" json:"idle_timeout_ns,omitempty"`
	// Table write: this field should be left unset.
	// Table read: if the table supports idle timeout and time_since_last_hit is
	// set in the request, this field will be set in the response.
	TimeSinceLastHit *TableEntry_IdleTimeout `protobuf:"bytes,10,opt,name=time_since_last_hit,json=timeSinceLastHit,proto3" json:"time_since_last_hit,omitempty"`
	// Arbitrary metadata from the controller that is opaque to the target.
	Metadata []byte `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// True if and only if the entry cannot be deleted or modified,
	// i.e. any of the following:
	//   - Any entry read from a table declared with `const entries`
	//   - The default entry read from a table declared with `const
	//     default_action`
	//   - Any entry declared with `entries` without the `const` qualifier
	//     before `entries`, where the individual entry has the `const`
	//     qualifier on it in the P4 source code.
	//
	// Note: Older P4Runtime API servers before the `is_const` field was
	// added to this message will not return a value for `is_const` in
	// the first two cases above, but newer P4Runtime API servers will.
	// Added in 1.4.0.
	IsConst bool `protobuf:"varint,13,opt,name=is_const,json=isConst,proto3" json:"is_const,omitempty"`
	// contains filtered or unexported fields
}

func (*TableEntry) Descriptor deprecated 

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

Deprecated: Use TableEntry.ProtoReflect.Descriptor instead.

func (*TableEntry) GetAction 

func (x *TableEntry) GetAction() *TableAction

func (*TableEntry) GetControllerMetadata deprecated 

func (x *TableEntry) GetControllerMetadata() uint64

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*TableEntry) GetCounterData 

func (x *TableEntry) GetCounterData() *CounterData

func (*TableEntry) GetIdleTimeoutNs 

func (x *TableEntry) GetIdleTimeoutNs() int64

func (*TableEntry) GetIsConst added in v1.4.0 

func (x *TableEntry) GetIsConst() bool

func (*TableEntry) GetIsDefaultAction 

func (x *TableEntry) GetIsDefaultAction() bool

func (*TableEntry) GetMatch 

func (x *TableEntry) GetMatch() []*FieldMatch

func (*TableEntry) GetMetadata 

func (x *TableEntry) GetMetadata() []byte

func (*TableEntry) GetMeterConfig 

func (x *TableEntry) GetMeterConfig() *MeterConfig

func (*TableEntry) GetMeterCounterData added in v1.4.0 

func (x *TableEntry) GetMeterCounterData() *MeterCounterData

func (*TableEntry) GetPriority 

func (x *TableEntry) GetPriority() int32

func (*TableEntry) GetTableId 

func (x *TableEntry) GetTableId() uint32

func (*TableEntry) GetTimeSinceLastHit 

func (x *TableEntry) GetTimeSinceLastHit() *TableEntry_IdleTimeout

func (*TableEntry) ProtoMessage 

func (*TableEntry) ProtoMessage()

func (*TableEntry) ProtoReflect added in v1.4.0 

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

func (*TableEntry) Reset 

func (x *TableEntry) Reset()

func (*TableEntry) String 

func (x *TableEntry) String() string

type TableEntry_IdleTimeout 

type TableEntry_IdleTimeout struct {

	// Time elapsed - in nanoseconds - since the table entry was last "hit" as
	// part of a data plane table lookup.
	ElapsedNs int64 `protobuf:"varint,1,opt,name=elapsed_ns,json=elapsedNs,proto3" json:"elapsed_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*TableEntry_IdleTimeout) Descriptor deprecated 

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

Deprecated: Use TableEntry_IdleTimeout.ProtoReflect.Descriptor instead.

func (*TableEntry_IdleTimeout) GetElapsedNs 

func (x *TableEntry_IdleTimeout) GetElapsedNs() int64

func (*TableEntry_IdleTimeout) ProtoMessage 

func (*TableEntry_IdleTimeout) ProtoMessage()

func (*TableEntry_IdleTimeout) ProtoReflect added in v1.4.0 

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

func (*TableEntry_IdleTimeout) Reset 

func (x *TableEntry_IdleTimeout) Reset()

func (*TableEntry_IdleTimeout) String 

func (x *TableEntry_IdleTimeout) String() string

type Uint128 

type Uint128 struct {

	// Highest 64 bits of a 128 bit number.
	High uint64 `protobuf:"varint,1,opt,name=high,proto3" json:"high,omitempty"`
	// Lowest 64 bits of a 128 bit number.
	Low uint64 `protobuf:"varint,2,opt,name=low,proto3" json:"low,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint128) Descriptor deprecated 

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

Deprecated: Use Uint128.ProtoReflect.Descriptor instead.

func (*Uint128) GetHigh 

func (x *Uint128) GetHigh() uint64

func (*Uint128) GetLow 

func (x *Uint128) GetLow() uint64

func (*Uint128) ProtoMessage 

func (*Uint128) ProtoMessage()

func (*Uint128) ProtoReflect added in v1.4.0 

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

func (*Uint128) Reset 

func (x *Uint128) Reset()

func (*Uint128) String 

func (x *Uint128) String() string

type UnimplementedP4RuntimeServer 

type UnimplementedP4RuntimeServer struct {
}

UnimplementedP4RuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedP4RuntimeServer) Capabilities 

func (UnimplementedP4RuntimeServer) Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)

func (UnimplementedP4RuntimeServer) GetForwardingPipelineConfig 

func (UnimplementedP4RuntimeServer) GetForwardingPipelineConfig(context.Context, *GetForwardingPipelineConfigRequest) (*GetForwardingPipelineConfigResponse, error)

func (UnimplementedP4RuntimeServer) Read 

func (UnimplementedP4RuntimeServer) Read(*ReadRequest, P4Runtime_ReadServer) error

func (UnimplementedP4RuntimeServer) SetForwardingPipelineConfig 

func (UnimplementedP4RuntimeServer) SetForwardingPipelineConfig(context.Context, *SetForwardingPipelineConfigRequest) (*SetForwardingPipelineConfigResponse, error)

func (UnimplementedP4RuntimeServer) StreamChannel 

func (UnimplementedP4RuntimeServer) StreamChannel(P4Runtime_StreamChannelServer) error

func (UnimplementedP4RuntimeServer) Write 

func (UnimplementedP4RuntimeServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

type UnsafeP4RuntimeServer added in v1.4.0 

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

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

type Update 

type Update struct {
	Type   Update_Type `protobuf:"varint,1,opt,name=type,proto3,enum=p4.v1.Update_Type" json:"type,omitempty"`
	Entity *Entity     `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*Update) Descriptor deprecated 

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetEntity 

func (x *Update) GetEntity() *Entity

func (*Update) GetType 

func (x *Update) GetType() Update_Type

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect added in v1.4.0 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

type Update_Type 

type Update_Type int32
const (
	Update_UNSPECIFIED Update_Type = 0
	Update_INSERT      Update_Type = 1
	Update_MODIFY      Update_Type = 2
	Update_DELETE      Update_Type = 3
)

func (Update_Type) Descriptor added in v1.4.0 

func (Update_Type) Descriptor() protoreflect.EnumDescriptor

func (Update_Type) Enum added in v1.4.0 

func (x Update_Type) Enum() *Update_Type

func (Update_Type) EnumDescriptor deprecated 

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

Deprecated: Use Update_Type.Descriptor instead.

func (Update_Type) Number added in v1.4.0 

func (x Update_Type) Number() protoreflect.EnumNumber

func (Update_Type) String 

func (x Update_Type) String() string

func (Update_Type) Type added in v1.4.0 

func (Update_Type) Type() protoreflect.EnumType

type ValueSetEntry 

type ValueSetEntry struct {
	ValueSetId uint32            `protobuf:"varint,1,opt,name=value_set_id,json=valueSetId,proto3" json:"value_set_id,omitempty"`
	Members    []*ValueSetMember `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------ For writing and reading matches in a parser value set. A state transition on an empty value set will never be taken. The number of matches must be at most the size of the value set as specified by the size argument of the value_set constructor in the P4 program.

For Write Requests:

  • MODIFY will write the given matches in the repeated field to the value set.
  • INSERT and DELETE are not allowed.

For Read Requests:

  • All matches for all value-set entries if value_set_id = 0
  • All matches of the value-set if a valid value_set_id is specified
  • The 'match' field must never be set in the ReadRequest

func (*ValueSetEntry) Descriptor deprecated 

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

Deprecated: Use ValueSetEntry.ProtoReflect.Descriptor instead.

func (*ValueSetEntry) GetMembers 

func (x *ValueSetEntry) GetMembers() []*ValueSetMember

func (*ValueSetEntry) GetValueSetId 

func (x *ValueSetEntry) GetValueSetId() uint32

func (*ValueSetEntry) ProtoMessage 

func (*ValueSetEntry) ProtoMessage()

func (*ValueSetEntry) ProtoReflect added in v1.4.0 

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

func (*ValueSetEntry) Reset 

func (x *ValueSetEntry) Reset()

func (*ValueSetEntry) String 

func (x *ValueSetEntry) String() string

type ValueSetMember 

type ValueSetMember struct {
	Match []*FieldMatch `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"`
	// contains filtered or unexported fields
}

A member in a P4 value set. Each member defines a list of matches, which can have different match types.

func (*ValueSetMember) Descriptor deprecated 

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

Deprecated: Use ValueSetMember.ProtoReflect.Descriptor instead.

func (*ValueSetMember) GetMatch 

func (x *ValueSetMember) GetMatch() []*FieldMatch

func (*ValueSetMember) ProtoMessage 

func (*ValueSetMember) ProtoMessage()

func (*ValueSetMember) ProtoReflect added in v1.4.0 

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

func (*ValueSetMember) Reset 

func (x *ValueSetMember) Reset()

func (*ValueSetMember) String 

func (x *ValueSetMember) String() string

type WriteRequest 

type WriteRequest struct {
	DeviceId uint64 `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// Deprecated in v1.4.0
	//
	// Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.
	RoleId uint64 `protobuf:"varint,2,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	// Added in v1.4.0
	Role       string   `protobuf:"bytes,6,opt,name=role,proto3" json:"role,omitempty"`
	ElectionId *Uint128 `protobuf:"bytes,3,opt,name=election_id,json=electionId,proto3" json:"election_id,omitempty"`
	// The write batch, comprising a list of Update operations. The P4Runtime
	// server may arbitrarily reorder messages within a batch to maximize
	// performance.
	Updates   []*Update              `protobuf:"bytes,4,rep,name=updates,proto3" json:"updates,omitempty"`
	Atomicity WriteRequest_Atomicity `protobuf:"varint,5,opt,name=atomicity,proto3,enum=p4.v1.WriteRequest_Atomicity" json:"atomicity,omitempty"`
	// contains filtered or unexported fields
}

------------------------------------------------------------------------------

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetAtomicity 

func (x *WriteRequest) GetAtomicity() WriteRequest_Atomicity

func (*WriteRequest) GetDeviceId 

func (x *WriteRequest) GetDeviceId() uint64

func (*WriteRequest) GetElectionId 

func (x *WriteRequest) GetElectionId() *Uint128

func (*WriteRequest) GetRole added in v1.4.0 

func (x *WriteRequest) GetRole() string

func (*WriteRequest) GetRoleId deprecated 

func (x *WriteRequest) GetRoleId() uint64

Deprecated: Marked as deprecated in p4/v1/p4runtime.proto.

func (*WriteRequest) GetUpdates 

func (x *WriteRequest) GetUpdates() []*Update

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect added in v1.4.0 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) String() string

type WriteRequest_Atomicity 

type WriteRequest_Atomicity int32
const (
	// Required. This is the default behavior. The batch is processed in a
	// non-atomic manner from a data plane point of view. Each operation within
	// the batch must be attempted even if one or more encounter errors.
	// Every data plane packet is guaranteed to be processed according to
	// table contents as they are between two individual operations of the
	// batch, but there could be several packets processed that see each of
	// these intermediate stages.
	WriteRequest_CONTINUE_ON_ERROR WriteRequest_Atomicity = 0
	// Optional. Operations within the batch are committed to data plane until
	// an error is encountered. At this point, the operations must be rolled
	// back such that both software and data plane state is consistent with the
	// state before the batch was attempted. The resulting behavior is
	// all-or-none, except the batch is not atomic from a data plane point of
	// view. Every data plane packet is guaranteed to be processed according to
	// table contents as they are between two individual operations of the
	// batch, but there could be several packets processed that see each of
	// these intermediate stages.
	WriteRequest_ROLLBACK_ON_ERROR WriteRequest_Atomicity = 1
	// Optional. Every data plane packet is guaranteed to be processed according
	// to table contents before the batch began, or after the batch completed
	// and the operations were programmed to the hardware.
	// The batch is therefore treated as a transaction.
	WriteRequest_DATAPLANE_ATOMIC WriteRequest_Atomicity = 2
)

func (WriteRequest_Atomicity) Descriptor added in v1.4.0 

func (WriteRequest_Atomicity) Descriptor() protoreflect.EnumDescriptor

func (WriteRequest_Atomicity) Enum added in v1.4.0 

func (x WriteRequest_Atomicity) Enum() *WriteRequest_Atomicity

func (WriteRequest_Atomicity) EnumDescriptor deprecated 

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

Deprecated: Use WriteRequest_Atomicity.Descriptor instead.

func (WriteRequest_Atomicity) Number added in v1.4.0 

func (x WriteRequest_Atomicity) Number() protoreflect.EnumNumber

func (WriteRequest_Atomicity) String 

func (x WriteRequest_Atomicity) String() string

func (WriteRequest_Atomicity) Type added in v1.4.0 

func (WriteRequest_Atomicity) Type() protoreflect.EnumType

type WriteResponse 

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

func (*WriteResponse) Descriptor deprecated 

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

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect added in v1.4.0 

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

func (*WriteResponse) Reset 

func (x *WriteResponse) Reset()

func (*WriteResponse) String 

func (x *WriteResponse) String() string

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.