v1

package
v1.0.1-0...-faca11d Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetForwardingPipelineConfigRequest_ResponseType_name = map[int32]string{
	0: "ALL",
	1: "COOKIE_ONLY",
	2: "P4INFO_AND_COOKIE",
	3: "DEVICE_CONFIG_AND_COOKIE",
}
View Source 
var GetForwardingPipelineConfigRequest_ResponseType_value = map[string]int32{
	"ALL":                      0,
	"COOKIE_ONLY":              1,
	"P4INFO_AND_COOKIE":        2,
	"DEVICE_CONFIG_AND_COOKIE": 3,
}
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",
}
View Source 
var 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,
}
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",
}
View Source 
var SetForwardingPipelineConfigRequest_Action_value = map[string]int32{
	"UNSPECIFIED":          0,
	"VERIFY":               1,
	"VERIFY_AND_SAVE":      2,
	"VERIFY_AND_COMMIT":    3,
	"COMMIT":               4,
	"RECONCILE_AND_COMMIT": 5,
}
View Source 
var Update_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "INSERT",
	2: "MODIFY",
	3: "DELETE",
}
View Source 
var Update_Type_value = map[string]int32{
	"UNSPECIFIED": 0,
	"INSERT":      1,
	"MODIFY":      2,
	"DELETE":      3,
}
View Source 
var WriteRequest_Atomicity_name = map[int32]string{
	0: "CONTINUE_ON_ERROR",
	1: "ROLLBACK_ON_ERROR",
	2: "DATAPLANE_ATOMIC",
}
View Source 
var WriteRequest_Atomicity_value = map[string]int32{
	"CONTINUE_ON_ERROR": 0,
	"ROLLBACK_ON_ERROR": 1,
	"DATAPLANE_ATOMIC":  2,
}

Functions

func RegisterP4RuntimeServer 

func RegisterP4RuntimeServer(s *grpc.Server, 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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Action) Descriptor 

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

func (*Action) GetActionId 

func (m *Action) GetActionId() uint32

func (*Action) GetParams 

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

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) String 

func (m *Action) String() string

func (*Action) XXX_DiscardUnknown 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal 

func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Action) XXX_Merge 

func (m *Action) XXX_Merge(src proto.Message)

func (*Action) XXX_Size 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal 

func (m *Action) XXX_Unmarshal(b []byte) error

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"`
	Watch                int32    `protobuf:"varint,3,opt,name=watch,proto3" json:"watch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActionProfileAction) Descriptor 

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

func (*ActionProfileAction) GetAction 

func (m *ActionProfileAction) GetAction() *Action

func (*ActionProfileAction) GetWatch 

func (m *ActionProfileAction) GetWatch() int32

func (*ActionProfileAction) GetWeight 

func (m *ActionProfileAction) GetWeight() int32

func (*ActionProfileAction) ProtoMessage 

func (*ActionProfileAction) ProtoMessage()

func (*ActionProfileAction) Reset 

func (m *ActionProfileAction) Reset()

func (*ActionProfileAction) String 

func (m *ActionProfileAction) String() string

func (*ActionProfileAction) XXX_DiscardUnknown 

func (m *ActionProfileAction) XXX_DiscardUnknown()

func (*ActionProfileAction) XXX_Marshal 

func (m *ActionProfileAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionProfileAction) XXX_Merge 

func (m *ActionProfileAction) XXX_Merge(src proto.Message)

func (*ActionProfileAction) XXX_Size 

func (m *ActionProfileAction) XXX_Size() int

func (*ActionProfileAction) XXX_Unmarshal 

func (m *ActionProfileAction) XXX_Unmarshal(b []byte) error

type ActionProfileActionSet 

type ActionProfileActionSet struct {
	ActionProfileActions []*ActionProfileAction `protobuf:"bytes,1,rep,name=action_profile_actions,json=actionProfileActions,proto3" json:"action_profile_actions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ActionProfileActionSet) Descriptor 

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

func (*ActionProfileActionSet) GetActionProfileActions 

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

func (*ActionProfileActionSet) ProtoMessage 

func (*ActionProfileActionSet) ProtoMessage()

func (*ActionProfileActionSet) Reset 

func (m *ActionProfileActionSet) Reset()

func (*ActionProfileActionSet) String 

func (m *ActionProfileActionSet) String() string

func (*ActionProfileActionSet) XXX_DiscardUnknown 

func (m *ActionProfileActionSet) XXX_DiscardUnknown()

func (*ActionProfileActionSet) XXX_Marshal 

func (m *ActionProfileActionSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionProfileActionSet) XXX_Merge 

func (m *ActionProfileActionSet) XXX_Merge(src proto.Message)

func (*ActionProfileActionSet) XXX_Size 

func (m *ActionProfileActionSet) XXX_Size() int

func (*ActionProfileActionSet) XXX_Unmarshal 

func (m *ActionProfileActionSet) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ActionProfileGroup) Descriptor 

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

func (*ActionProfileGroup) GetActionProfileId 

func (m *ActionProfileGroup) GetActionProfileId() uint32

func (*ActionProfileGroup) GetGroupId 

func (m *ActionProfileGroup) GetGroupId() uint32

func (*ActionProfileGroup) GetMaxSize 

func (m *ActionProfileGroup) GetMaxSize() int32

func (*ActionProfileGroup) GetMembers 

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

func (*ActionProfileGroup) ProtoMessage 

func (*ActionProfileGroup) ProtoMessage()

func (*ActionProfileGroup) Reset 

func (m *ActionProfileGroup) Reset()

func (*ActionProfileGroup) String 

func (m *ActionProfileGroup) String() string

func (*ActionProfileGroup) XXX_DiscardUnknown 

func (m *ActionProfileGroup) XXX_DiscardUnknown()

func (*ActionProfileGroup) XXX_Marshal 

func (m *ActionProfileGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionProfileGroup) XXX_Merge 

func (m *ActionProfileGroup) XXX_Merge(src proto.Message)

func (*ActionProfileGroup) XXX_Size 

func (m *ActionProfileGroup) XXX_Size() int

func (*ActionProfileGroup) XXX_Unmarshal 

func (m *ActionProfileGroup) XXX_Unmarshal(b []byte) error

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"`
	Watch                uint32   `protobuf:"varint,3,opt,name=watch,proto3" json:"watch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActionProfileGroup_Member) Descriptor 

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

func (*ActionProfileGroup_Member) GetMemberId 

func (m *ActionProfileGroup_Member) GetMemberId() uint32

func (*ActionProfileGroup_Member) GetWatch 

func (m *ActionProfileGroup_Member) GetWatch() uint32

func (*ActionProfileGroup_Member) GetWeight 

func (m *ActionProfileGroup_Member) GetWeight() int32

func (*ActionProfileGroup_Member) ProtoMessage 

func (*ActionProfileGroup_Member) ProtoMessage()

func (*ActionProfileGroup_Member) Reset 

func (m *ActionProfileGroup_Member) Reset()

func (*ActionProfileGroup_Member) String 

func (m *ActionProfileGroup_Member) String() string

func (*ActionProfileGroup_Member) XXX_DiscardUnknown 

func (m *ActionProfileGroup_Member) XXX_DiscardUnknown()

func (*ActionProfileGroup_Member) XXX_Marshal 

func (m *ActionProfileGroup_Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionProfileGroup_Member) XXX_Merge 

func (m *ActionProfileGroup_Member) XXX_Merge(src proto.Message)

func (*ActionProfileGroup_Member) XXX_Size 

func (m *ActionProfileGroup_Member) XXX_Size() int

func (*ActionProfileGroup_Member) XXX_Unmarshal 

func (m *ActionProfileGroup_Member) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ActionProfileMember) Descriptor 

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

func (*ActionProfileMember) GetAction 

func (m *ActionProfileMember) GetAction() *Action

func (*ActionProfileMember) GetActionProfileId 

func (m *ActionProfileMember) GetActionProfileId() uint32

func (*ActionProfileMember) GetMemberId 

func (m *ActionProfileMember) GetMemberId() uint32

func (*ActionProfileMember) ProtoMessage 

func (*ActionProfileMember) ProtoMessage()

func (*ActionProfileMember) Reset 

func (m *ActionProfileMember) Reset()

func (*ActionProfileMember) String 

func (m *ActionProfileMember) String() string

func (*ActionProfileMember) XXX_DiscardUnknown 

func (m *ActionProfileMember) XXX_DiscardUnknown()

func (*ActionProfileMember) XXX_Marshal 

func (m *ActionProfileMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionProfileMember) XXX_Merge 

func (m *ActionProfileMember) XXX_Merge(src proto.Message)

func (*ActionProfileMember) XXX_Size 

func (m *ActionProfileMember) XXX_Size() int

func (*ActionProfileMember) XXX_Unmarshal 

func (m *ActionProfileMember) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Action_Param) Descriptor 

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

func (*Action_Param) GetParamId 

func (m *Action_Param) GetParamId() uint32

func (*Action_Param) GetValue 

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

func (*Action_Param) ProtoMessage 

func (*Action_Param) ProtoMessage()

func (*Action_Param) Reset 

func (m *Action_Param) Reset()

func (*Action_Param) String 

func (m *Action_Param) String() string

func (*Action_Param) XXX_DiscardUnknown 

func (m *Action_Param) XXX_DiscardUnknown()

func (*Action_Param) XXX_Marshal 

func (m *Action_Param) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Action_Param) XXX_Merge 

func (m *Action_Param) XXX_Merge(src proto.Message)

func (*Action_Param) XXX_Size 

func (m *Action_Param) XXX_Size() int

func (*Action_Param) XXX_Unmarshal 

func (m *Action_Param) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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 

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

func (*CloneSessionEntry) GetClassOfService 

func (m *CloneSessionEntry) GetClassOfService() uint32

func (*CloneSessionEntry) GetPacketLengthBytes 

func (m *CloneSessionEntry) GetPacketLengthBytes() int32

func (*CloneSessionEntry) GetReplicas 

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

func (*CloneSessionEntry) GetSessionId 

func (m *CloneSessionEntry) GetSessionId() uint32

func (*CloneSessionEntry) ProtoMessage 

func (*CloneSessionEntry) ProtoMessage()

func (*CloneSessionEntry) Reset 

func (m *CloneSessionEntry) Reset()

func (*CloneSessionEntry) String 

func (m *CloneSessionEntry) String() string

func (*CloneSessionEntry) XXX_DiscardUnknown 

func (m *CloneSessionEntry) XXX_DiscardUnknown()

func (*CloneSessionEntry) XXX_Marshal 

func (m *CloneSessionEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloneSessionEntry) XXX_Merge 

func (m *CloneSessionEntry) XXX_Merge(src proto.Message)

func (*CloneSessionEntry) XXX_Size 

func (m *CloneSessionEntry) XXX_Size() int

func (*CloneSessionEntry) XXX_Unmarshal 

func (m *CloneSessionEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CounterData) Descriptor 

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

func (*CounterData) GetByteCount 

func (m *CounterData) GetByteCount() int64

func (*CounterData) GetPacketCount 

func (m *CounterData) GetPacketCount() int64

func (*CounterData) ProtoMessage 

func (*CounterData) ProtoMessage()

func (*CounterData) Reset 

func (m *CounterData) Reset()

func (*CounterData) String 

func (m *CounterData) String() string

func (*CounterData) XXX_DiscardUnknown 

func (m *CounterData) XXX_DiscardUnknown()

func (*CounterData) XXX_Marshal 

func (m *CounterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CounterData) XXX_Merge 

func (m *CounterData) XXX_Merge(src proto.Message)

func (*CounterData) XXX_Size 

func (m *CounterData) XXX_Size() int

func (*CounterData) XXX_Unmarshal 

func (m *CounterData) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*CounterEntry) GetCounterId 

func (m *CounterEntry) GetCounterId() uint32

func (*CounterEntry) GetData 

func (m *CounterEntry) GetData() *CounterData

func (*CounterEntry) GetIndex 

func (m *CounterEntry) GetIndex() *Index

func (*CounterEntry) ProtoMessage 

func (*CounterEntry) ProtoMessage()

func (*CounterEntry) Reset 

func (m *CounterEntry) Reset()

func (*CounterEntry) String 

func (m *CounterEntry) String() string

func (*CounterEntry) XXX_DiscardUnknown 

func (m *CounterEntry) XXX_DiscardUnknown()

func (*CounterEntry) XXX_Marshal 

func (m *CounterEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CounterEntry) XXX_Merge 

func (m *CounterEntry) XXX_Merge(src proto.Message)

func (*CounterEntry) XXX_Size 

func (m *CounterEntry) XXX_Size() int

func (*CounterEntry) XXX_Unmarshal 

func (m *CounterEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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

func (*DigestEntry) Descriptor 

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

func (*DigestEntry) GetConfig 

func (m *DigestEntry) GetConfig() *DigestEntry_Config

func (*DigestEntry) GetDigestId 

func (m *DigestEntry) GetDigestId() uint32

func (*DigestEntry) ProtoMessage 

func (*DigestEntry) ProtoMessage()

func (*DigestEntry) Reset 

func (m *DigestEntry) Reset()

func (*DigestEntry) String 

func (m *DigestEntry) String() string

func (*DigestEntry) XXX_DiscardUnknown 

func (m *DigestEntry) XXX_DiscardUnknown()

func (*DigestEntry) XXX_Marshal 

func (m *DigestEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DigestEntry) XXX_Merge 

func (m *DigestEntry) XXX_Merge(src proto.Message)

func (*DigestEntry) XXX_Size 

func (m *DigestEntry) XXX_Size() int

func (*DigestEntry) XXX_Unmarshal 

func (m *DigestEntry) XXX_Unmarshal(b []byte) error

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"`
	MaxListSize          int32    `protobuf:"varint,2,opt,name=max_list_size,json=maxListSize,proto3" json:"max_list_size,omitempty"`
	AckTimeoutNs         int64    `protobuf:"varint,3,opt,name=ack_timeout_ns,json=ackTimeoutNs,proto3" json:"ack_timeout_ns,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*DigestEntry_Config) GetAckTimeoutNs 

func (m *DigestEntry_Config) GetAckTimeoutNs() int64

func (*DigestEntry_Config) GetMaxListSize 

func (m *DigestEntry_Config) GetMaxListSize() int32

func (*DigestEntry_Config) GetMaxTimeoutNs 

func (m *DigestEntry_Config) GetMaxTimeoutNs() int64

func (*DigestEntry_Config) ProtoMessage 

func (*DigestEntry_Config) ProtoMessage()

func (*DigestEntry_Config) Reset 

func (m *DigestEntry_Config) Reset()

func (*DigestEntry_Config) String 

func (m *DigestEntry_Config) String() string

func (*DigestEntry_Config) XXX_DiscardUnknown 

func (m *DigestEntry_Config) XXX_DiscardUnknown()

func (*DigestEntry_Config) XXX_Marshal 

func (m *DigestEntry_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DigestEntry_Config) XXX_Merge 

func (m *DigestEntry_Config) XXX_Merge(src proto.Message)

func (*DigestEntry_Config) XXX_Size 

func (m *DigestEntry_Config) XXX_Size() int

func (*DigestEntry_Config) XXX_Unmarshal 

func (m *DigestEntry_Config) XXX_Unmarshal(b []byte) error

type DigestList 

type DigestList 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"`
	// 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DigestList) Descriptor 

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

func (*DigestList) GetData 

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

func (*DigestList) GetDigestId 

func (m *DigestList) GetDigestId() uint32

func (*DigestList) GetListId 

func (m *DigestList) GetListId() uint64

func (*DigestList) GetTimestamp 

func (m *DigestList) GetTimestamp() int64

func (*DigestList) ProtoMessage 

func (*DigestList) ProtoMessage()

func (*DigestList) Reset 

func (m *DigestList) Reset()

func (*DigestList) String 

func (m *DigestList) String() string

func (*DigestList) XXX_DiscardUnknown 

func (m *DigestList) XXX_DiscardUnknown()

func (*DigestList) XXX_Marshal 

func (m *DigestList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DigestList) XXX_Merge 

func (m *DigestList) XXX_Merge(src proto.Message)

func (*DigestList) XXX_Size 

func (m *DigestList) XXX_Size() int

func (*DigestList) XXX_Unmarshal 

func (m *DigestList) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*DigestListAck) GetDigestId 

func (m *DigestListAck) GetDigestId() uint32

func (*DigestListAck) GetListId 

func (m *DigestListAck) GetListId() uint64

func (*DigestListAck) ProtoMessage 

func (*DigestListAck) ProtoMessage()

func (*DigestListAck) Reset 

func (m *DigestListAck) Reset()

func (*DigestListAck) String 

func (m *DigestListAck) String() string

func (*DigestListAck) XXX_DiscardUnknown 

func (m *DigestListAck) XXX_DiscardUnknown()

func (*DigestListAck) XXX_Marshal 

func (m *DigestListAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DigestListAck) XXX_Merge 

func (m *DigestListAck) XXX_Merge(src proto.Message)

func (*DigestListAck) XXX_Size 

func (m *DigestListAck) XXX_Size() int

func (*DigestListAck) XXX_Unmarshal 

func (m *DigestListAck) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*DirectCounterEntry) GetData 

func (m *DirectCounterEntry) GetData() *CounterData

func (*DirectCounterEntry) GetTableEntry 

func (m *DirectCounterEntry) GetTableEntry() *TableEntry

func (*DirectCounterEntry) ProtoMessage 

func (*DirectCounterEntry) ProtoMessage()

func (*DirectCounterEntry) Reset 

func (m *DirectCounterEntry) Reset()

func (*DirectCounterEntry) String 

func (m *DirectCounterEntry) String() string

func (*DirectCounterEntry) XXX_DiscardUnknown 

func (m *DirectCounterEntry) XXX_DiscardUnknown()

func (*DirectCounterEntry) XXX_Marshal 

func (m *DirectCounterEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DirectCounterEntry) XXX_Merge 

func (m *DirectCounterEntry) XXX_Merge(src proto.Message)

func (*DirectCounterEntry) XXX_Size 

func (m *DirectCounterEntry) XXX_Size() int

func (*DirectCounterEntry) XXX_Unmarshal 

func (m *DirectCounterEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*DirectMeterEntry) GetConfig 

func (m *DirectMeterEntry) GetConfig() *MeterConfig

func (*DirectMeterEntry) GetTableEntry 

func (m *DirectMeterEntry) GetTableEntry() *TableEntry

func (*DirectMeterEntry) ProtoMessage 

func (*DirectMeterEntry) ProtoMessage()

func (*DirectMeterEntry) Reset 

func (m *DirectMeterEntry) Reset()

func (*DirectMeterEntry) String 

func (m *DirectMeterEntry) String() string

func (*DirectMeterEntry) XXX_DiscardUnknown 

func (m *DirectMeterEntry) XXX_DiscardUnknown()

func (*DirectMeterEntry) XXX_Marshal 

func (m *DirectMeterEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DirectMeterEntry) XXX_Merge 

func (m *DirectMeterEntry) XXX_Merge(src proto.Message)

func (*DirectMeterEntry) XXX_Size 

func (m *DirectMeterEntry) XXX_Size() int

func (*DirectMeterEntry) XXX_Unmarshal 

func (m *DirectMeterEntry) XXX_Unmarshal(b []byte) error

type Entity 

type Entity struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Entity) Descriptor 

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

func (*Entity) GetActionProfileGroup 

func (m *Entity) GetActionProfileGroup() *ActionProfileGroup

func (*Entity) GetActionProfileMember 

func (m *Entity) GetActionProfileMember() *ActionProfileMember

func (*Entity) GetCounterEntry 

func (m *Entity) GetCounterEntry() *CounterEntry

func (*Entity) GetDigestEntry 

func (m *Entity) GetDigestEntry() *DigestEntry

func (*Entity) GetDirectCounterEntry 

func (m *Entity) GetDirectCounterEntry() *DirectCounterEntry

func (*Entity) GetDirectMeterEntry 

func (m *Entity) GetDirectMeterEntry() *DirectMeterEntry

func (*Entity) GetEntity 

func (m *Entity) GetEntity() isEntity_Entity

func (*Entity) GetExternEntry 

func (m *Entity) GetExternEntry() *ExternEntry

func (*Entity) GetMeterEntry 

func (m *Entity) GetMeterEntry() *MeterEntry

func (*Entity) GetPacketReplicationEngineEntry 

func (m *Entity) GetPacketReplicationEngineEntry() *PacketReplicationEngineEntry

func (*Entity) GetRegisterEntry 

func (m *Entity) GetRegisterEntry() *RegisterEntry

func (*Entity) GetTableEntry 

func (m *Entity) GetTableEntry() *TableEntry

func (*Entity) GetValueSetEntry 

func (m *Entity) GetValueSetEntry() *ValueSetEntry

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge 

func (m *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_OneofWrappers 

func (*Entity) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

func (m *Entity) XXX_Unmarshal(b []byte) error

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
	// github.com/grpc/grpc-go/blob/master/codes/codes.go)
	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              *any.Any `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Error) Descriptor 

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

func (*Error) GetCanonicalCode 

func (m *Error) GetCanonicalCode() int32

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetDetails 

func (m *Error) GetDetails() *any.Any

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetSpace 

func (m *Error) GetSpace() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

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"`
	Entry                *any.Any `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExternEntry) Descriptor 

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

func (*ExternEntry) GetEntry 

func (m *ExternEntry) GetEntry() *any.Any

func (*ExternEntry) GetExternId 

func (m *ExternEntry) GetExternId() uint32

func (*ExternEntry) GetExternTypeId 

func (m *ExternEntry) GetExternTypeId() uint32

func (*ExternEntry) ProtoMessage 

func (*ExternEntry) ProtoMessage()

func (*ExternEntry) Reset 

func (m *ExternEntry) Reset()

func (*ExternEntry) String 

func (m *ExternEntry) String() string

func (*ExternEntry) XXX_DiscardUnknown 

func (m *ExternEntry) XXX_DiscardUnknown()

func (*ExternEntry) XXX_Marshal 

func (m *ExternEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternEntry) XXX_Merge 

func (m *ExternEntry) XXX_Merge(src proto.Message)

func (*ExternEntry) XXX_Size 

func (m *ExternEntry) XXX_Size() int

func (*ExternEntry) XXX_Unmarshal 

func (m *ExternEntry) XXX_Unmarshal(b []byte) error

type FieldMatch 

type FieldMatch struct {
	FieldId uint32 `protobuf:"varint,1,opt,name=field_id,json=fieldId,proto3" json:"field_id,omitempty"`
	// Types that are valid to be assigned to FieldMatchType:
	//	*FieldMatch_Exact_
	//	*FieldMatch_Ternary_
	//	*FieldMatch_Lpm
	//	*FieldMatch_Range_
	//	*FieldMatch_Other
	FieldMatchType       isFieldMatch_FieldMatchType `protobuf_oneof:"field_match_type"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

field_match_type ::= exact | ternary | lpm | range

func (*FieldMatch) Descriptor 

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

func (*FieldMatch) GetExact 

func (m *FieldMatch) GetExact() *FieldMatch_Exact

func (*FieldMatch) GetFieldId 

func (m *FieldMatch) GetFieldId() uint32

func (*FieldMatch) GetFieldMatchType 

func (m *FieldMatch) GetFieldMatchType() isFieldMatch_FieldMatchType

func (*FieldMatch) GetLpm 

func (m *FieldMatch) GetLpm() *FieldMatch_LPM

func (*FieldMatch) GetOther 

func (m *FieldMatch) GetOther() *any.Any

func (*FieldMatch) GetRange 

func (m *FieldMatch) GetRange() *FieldMatch_Range

func (*FieldMatch) GetTernary 

func (m *FieldMatch) GetTernary() *FieldMatch_Ternary

func (*FieldMatch) ProtoMessage 

func (*FieldMatch) ProtoMessage()

func (*FieldMatch) Reset 

func (m *FieldMatch) Reset()

func (*FieldMatch) String 

func (m *FieldMatch) String() string

func (*FieldMatch) XXX_DiscardUnknown 

func (m *FieldMatch) XXX_DiscardUnknown()

func (*FieldMatch) XXX_Marshal 

func (m *FieldMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldMatch) XXX_Merge 

func (m *FieldMatch) XXX_Merge(src proto.Message)

func (*FieldMatch) XXX_OneofWrappers 

func (*FieldMatch) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FieldMatch) XXX_Size 

func (m *FieldMatch) XXX_Size() int

func (*FieldMatch) XXX_Unmarshal 

func (m *FieldMatch) XXX_Unmarshal(b []byte) error

type FieldMatch_Exact 

type FieldMatch_Exact struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*FieldMatch_Exact) Descriptor 

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

func (*FieldMatch_Exact) GetValue 

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

func (*FieldMatch_Exact) ProtoMessage 

func (*FieldMatch_Exact) ProtoMessage()

func (*FieldMatch_Exact) Reset 

func (m *FieldMatch_Exact) Reset()

func (*FieldMatch_Exact) String 

func (m *FieldMatch_Exact) String() string

func (*FieldMatch_Exact) XXX_DiscardUnknown 

func (m *FieldMatch_Exact) XXX_DiscardUnknown()

func (*FieldMatch_Exact) XXX_Marshal 

func (m *FieldMatch_Exact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldMatch_Exact) XXX_Merge 

func (m *FieldMatch_Exact) XXX_Merge(src proto.Message)

func (*FieldMatch_Exact) XXX_Size 

func (m *FieldMatch_Exact) XXX_Size() int

func (*FieldMatch_Exact) XXX_Unmarshal 

func (m *FieldMatch_Exact) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldMatch_LPM) Descriptor 

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

func (*FieldMatch_LPM) GetPrefixLen 

func (m *FieldMatch_LPM) GetPrefixLen() int32

func (*FieldMatch_LPM) GetValue 

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

func (*FieldMatch_LPM) ProtoMessage 

func (*FieldMatch_LPM) ProtoMessage()

func (*FieldMatch_LPM) Reset 

func (m *FieldMatch_LPM) Reset()

func (*FieldMatch_LPM) String 

func (m *FieldMatch_LPM) String() string

func (*FieldMatch_LPM) XXX_DiscardUnknown 

func (m *FieldMatch_LPM) XXX_DiscardUnknown()

func (*FieldMatch_LPM) XXX_Marshal 

func (m *FieldMatch_LPM) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldMatch_LPM) XXX_Merge 

func (m *FieldMatch_LPM) XXX_Merge(src proto.Message)

func (*FieldMatch_LPM) XXX_Size 

func (m *FieldMatch_LPM) XXX_Size() int

func (*FieldMatch_LPM) XXX_Unmarshal 

func (m *FieldMatch_LPM) XXX_Unmarshal(b []byte) error

type FieldMatch_Lpm 

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

type FieldMatch_Other 

type FieldMatch_Other struct {
	Other *any.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*FieldMatch_Range) Descriptor 

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

func (*FieldMatch_Range) GetHigh 

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

func (*FieldMatch_Range) GetLow 

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

func (*FieldMatch_Range) ProtoMessage 

func (*FieldMatch_Range) ProtoMessage()

func (*FieldMatch_Range) Reset 

func (m *FieldMatch_Range) Reset()

func (*FieldMatch_Range) String 

func (m *FieldMatch_Range) String() string

func (*FieldMatch_Range) XXX_DiscardUnknown 

func (m *FieldMatch_Range) XXX_DiscardUnknown()

func (*FieldMatch_Range) XXX_Marshal 

func (m *FieldMatch_Range) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldMatch_Range) XXX_Merge 

func (m *FieldMatch_Range) XXX_Merge(src proto.Message)

func (*FieldMatch_Range) XXX_Size 

func (m *FieldMatch_Range) XXX_Size() int

func (*FieldMatch_Range) XXX_Unmarshal 

func (m *FieldMatch_Range) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldMatch_Ternary) Descriptor 

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

func (*FieldMatch_Ternary) GetMask 

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

func (*FieldMatch_Ternary) GetValue 

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

func (*FieldMatch_Ternary) ProtoMessage 

func (*FieldMatch_Ternary) ProtoMessage()

func (*FieldMatch_Ternary) Reset 

func (m *FieldMatch_Ternary) Reset()

func (*FieldMatch_Ternary) String 

func (m *FieldMatch_Ternary) String() string

func (*FieldMatch_Ternary) XXX_DiscardUnknown 

func (m *FieldMatch_Ternary) XXX_DiscardUnknown()

func (*FieldMatch_Ternary) XXX_Marshal 

func (m *FieldMatch_Ternary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldMatch_Ternary) XXX_Merge 

func (m *FieldMatch_Ternary) XXX_Merge(src proto.Message)

func (*FieldMatch_Ternary) XXX_Size 

func (m *FieldMatch_Ternary) XXX_Size() int

func (*FieldMatch_Ternary) XXX_Unmarshal 

func (m *FieldMatch_Ternary) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*ForwardingPipelineConfig) Descriptor 

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

func (*ForwardingPipelineConfig) GetCookie 

func (m *ForwardingPipelineConfig) GetCookie() *ForwardingPipelineConfig_Cookie

func (*ForwardingPipelineConfig) GetP4DeviceConfig 

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

func (*ForwardingPipelineConfig) GetP4Info 

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

func (*ForwardingPipelineConfig) ProtoMessage 

func (*ForwardingPipelineConfig) ProtoMessage()

func (*ForwardingPipelineConfig) Reset 

func (m *ForwardingPipelineConfig) Reset()

func (*ForwardingPipelineConfig) String 

func (m *ForwardingPipelineConfig) String() string

func (*ForwardingPipelineConfig) XXX_DiscardUnknown 

func (m *ForwardingPipelineConfig) XXX_DiscardUnknown()

func (*ForwardingPipelineConfig) XXX_Marshal 

func (m *ForwardingPipelineConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardingPipelineConfig) XXX_Merge 

func (m *ForwardingPipelineConfig) XXX_Merge(src proto.Message)

func (*ForwardingPipelineConfig) XXX_Size 

func (m *ForwardingPipelineConfig) XXX_Size() int

func (*ForwardingPipelineConfig) XXX_Unmarshal 

func (m *ForwardingPipelineConfig) XXX_Unmarshal(b []byte) error
type ForwardingPipelineConfig_Cookie struct {
	Cookie               uint64   `protobuf:"varint,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*ForwardingPipelineConfig_Cookie) GetCookie 

func (m *ForwardingPipelineConfig_Cookie) GetCookie() uint64

func (*ForwardingPipelineConfig_Cookie) ProtoMessage 

func (*ForwardingPipelineConfig_Cookie) ProtoMessage()

func (*ForwardingPipelineConfig_Cookie) Reset 

func (m *ForwardingPipelineConfig_Cookie) Reset()

func (*ForwardingPipelineConfig_Cookie) String 

func (m *ForwardingPipelineConfig_Cookie) String() string

func (*ForwardingPipelineConfig_Cookie) XXX_DiscardUnknown 

func (m *ForwardingPipelineConfig_Cookie) XXX_DiscardUnknown()

func (*ForwardingPipelineConfig_Cookie) XXX_Marshal 

func (m *ForwardingPipelineConfig_Cookie) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardingPipelineConfig_Cookie) XXX_Merge 

func (m *ForwardingPipelineConfig_Cookie) XXX_Merge(src proto.Message)

func (*ForwardingPipelineConfig_Cookie) XXX_Size 

func (m *ForwardingPipelineConfig_Cookie) XXX_Size() int

func (*ForwardingPipelineConfig_Cookie) XXX_Unmarshal 

func (m *ForwardingPipelineConfig_Cookie) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*GetForwardingPipelineConfigRequest) Descriptor 

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

func (*GetForwardingPipelineConfigRequest) GetDeviceId 

func (m *GetForwardingPipelineConfigRequest) GetDeviceId() uint64

func (*GetForwardingPipelineConfigRequest) GetResponseType 

func (m *GetForwardingPipelineConfigRequest) GetResponseType() GetForwardingPipelineConfigRequest_ResponseType

func (*GetForwardingPipelineConfigRequest) ProtoMessage 

func (*GetForwardingPipelineConfigRequest) ProtoMessage()

func (*GetForwardingPipelineConfigRequest) Reset 

func (m *GetForwardingPipelineConfigRequest) Reset()

func (*GetForwardingPipelineConfigRequest) String 

func (m *GetForwardingPipelineConfigRequest) String() string

func (*GetForwardingPipelineConfigRequest) XXX_DiscardUnknown 

func (m *GetForwardingPipelineConfigRequest) XXX_DiscardUnknown()

func (*GetForwardingPipelineConfigRequest) XXX_Marshal 

func (m *GetForwardingPipelineConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetForwardingPipelineConfigRequest) XXX_Merge 

func (m *GetForwardingPipelineConfigRequest) XXX_Merge(src proto.Message)

func (*GetForwardingPipelineConfigRequest) XXX_Size 

func (m *GetForwardingPipelineConfigRequest) XXX_Size() int

func (*GetForwardingPipelineConfigRequest) XXX_Unmarshal 

func (m *GetForwardingPipelineConfigRequest) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (GetForwardingPipelineConfigRequest_ResponseType) String 

func (x GetForwardingPipelineConfigRequest_ResponseType) String() string

type GetForwardingPipelineConfigResponse 

type GetForwardingPipelineConfigResponse struct {
	Config               *ForwardingPipelineConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetForwardingPipelineConfigResponse) Descriptor 

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

func (*GetForwardingPipelineConfigResponse) GetConfig 

func (m *GetForwardingPipelineConfigResponse) GetConfig() *ForwardingPipelineConfig

func (*GetForwardingPipelineConfigResponse) ProtoMessage 

func (*GetForwardingPipelineConfigResponse) ProtoMessage()

func (*GetForwardingPipelineConfigResponse) Reset 

func (m *GetForwardingPipelineConfigResponse) Reset()

func (*GetForwardingPipelineConfigResponse) String 

func (m *GetForwardingPipelineConfigResponse) String() string

func (*GetForwardingPipelineConfigResponse) XXX_DiscardUnknown 

func (m *GetForwardingPipelineConfigResponse) XXX_DiscardUnknown()

func (*GetForwardingPipelineConfigResponse) XXX_Marshal 

func (m *GetForwardingPipelineConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetForwardingPipelineConfigResponse) XXX_Merge 

func (m *GetForwardingPipelineConfigResponse) XXX_Merge(src proto.Message)

func (*GetForwardingPipelineConfigResponse) XXX_Size 

func (m *GetForwardingPipelineConfigResponse) XXX_Size() int

func (*GetForwardingPipelineConfigResponse) XXX_Unmarshal 

func (m *GetForwardingPipelineConfigResponse) XXX_Unmarshal(b []byte) error

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
	// 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IdleTimeoutNotification) Descriptor 

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

func (*IdleTimeoutNotification) GetTableEntry 

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

func (*IdleTimeoutNotification) GetTimestamp 

func (m *IdleTimeoutNotification) GetTimestamp() int64

func (*IdleTimeoutNotification) ProtoMessage 

func (*IdleTimeoutNotification) ProtoMessage()

func (*IdleTimeoutNotification) Reset 

func (m *IdleTimeoutNotification) Reset()

func (*IdleTimeoutNotification) String 

func (m *IdleTimeoutNotification) String() string

func (*IdleTimeoutNotification) XXX_DiscardUnknown 

func (m *IdleTimeoutNotification) XXX_DiscardUnknown()

func (*IdleTimeoutNotification) XXX_Marshal 

func (m *IdleTimeoutNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IdleTimeoutNotification) XXX_Merge 

func (m *IdleTimeoutNotification) XXX_Merge(src proto.Message)

func (*IdleTimeoutNotification) XXX_Size 

func (m *IdleTimeoutNotification) XXX_Size() int

func (*IdleTimeoutNotification) XXX_Unmarshal 

func (m *IdleTimeoutNotification) XXX_Unmarshal(b []byte) error

type Index 

type Index struct {
	Index                int64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*Index) GetIndex 

func (m *Index) GetIndex() int64

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) String 

func (m *Index) String() string

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index) XXX_Merge 

func (m *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

func (m *Index) XXX_Unmarshal(b []byte) error

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 mastership is being arbitrated. For use-cases where
	// 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 master. The 'master'
	// 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 master, and with
	// an error status for all other connected clients (at every mastership
	// change). The controller does not populate this field.
	Status               *status.Status `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MasterArbitrationUpdate) Descriptor 

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

func (*MasterArbitrationUpdate) GetDeviceId 

func (m *MasterArbitrationUpdate) GetDeviceId() uint64

func (*MasterArbitrationUpdate) GetElectionId 

func (m *MasterArbitrationUpdate) GetElectionId() *Uint128

func (*MasterArbitrationUpdate) GetRole 

func (m *MasterArbitrationUpdate) GetRole() *Role

func (*MasterArbitrationUpdate) GetStatus 

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

func (*MasterArbitrationUpdate) ProtoMessage 

func (*MasterArbitrationUpdate) ProtoMessage()

func (*MasterArbitrationUpdate) Reset 

func (m *MasterArbitrationUpdate) Reset()

func (*MasterArbitrationUpdate) String 

func (m *MasterArbitrationUpdate) String() string

func (*MasterArbitrationUpdate) XXX_DiscardUnknown 

func (m *MasterArbitrationUpdate) XXX_DiscardUnknown()

func (*MasterArbitrationUpdate) XXX_Marshal 

func (m *MasterArbitrationUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MasterArbitrationUpdate) XXX_Merge 

func (m *MasterArbitrationUpdate) XXX_Merge(src proto.Message)

func (*MasterArbitrationUpdate) XXX_Size 

func (m *MasterArbitrationUpdate) XXX_Size() int

func (*MasterArbitrationUpdate) XXX_Unmarshal 

func (m *MasterArbitrationUpdate) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Modeled as RFC 2698: A Two Rate Three Color Marker (trTCM) 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.

func (*MeterConfig) Descriptor 

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

func (*MeterConfig) GetCburst 

func (m *MeterConfig) GetCburst() int64

func (*MeterConfig) GetCir 

func (m *MeterConfig) GetCir() int64

func (*MeterConfig) GetPburst 

func (m *MeterConfig) GetPburst() int64

func (*MeterConfig) GetPir 

func (m *MeterConfig) GetPir() int64

func (*MeterConfig) ProtoMessage 

func (*MeterConfig) ProtoMessage()

func (*MeterConfig) Reset 

func (m *MeterConfig) Reset()

func (*MeterConfig) String 

func (m *MeterConfig) String() string

func (*MeterConfig) XXX_DiscardUnknown 

func (m *MeterConfig) XXX_DiscardUnknown()

func (*MeterConfig) XXX_Marshal 

func (m *MeterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeterConfig) XXX_Merge 

func (m *MeterConfig) XXX_Merge(src proto.Message)

func (*MeterConfig) XXX_Size 

func (m *MeterConfig) XXX_Size() int

func (*MeterConfig) XXX_Unmarshal 

func (m *MeterConfig) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*MeterEntry) GetConfig 

func (m *MeterEntry) GetConfig() *MeterConfig

func (*MeterEntry) GetIndex 

func (m *MeterEntry) GetIndex() *Index

func (*MeterEntry) GetMeterId 

func (m *MeterEntry) GetMeterId() uint32

func (*MeterEntry) ProtoMessage 

func (*MeterEntry) ProtoMessage()

func (*MeterEntry) Reset 

func (m *MeterEntry) Reset()

func (*MeterEntry) String 

func (m *MeterEntry) String() string

func (*MeterEntry) XXX_DiscardUnknown 

func (m *MeterEntry) XXX_DiscardUnknown()

func (*MeterEntry) XXX_Marshal 

func (m *MeterEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeterEntry) XXX_Merge 

func (m *MeterEntry) XXX_Merge(src proto.Message)

func (*MeterEntry) XXX_Size 

func (m *MeterEntry) XXX_Size() int

func (*MeterEntry) XXX_Unmarshal 

func (m *MeterEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

The (egress_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 egress_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 

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

func (*MulticastGroupEntry) GetMulticastGroupId 

func (m *MulticastGroupEntry) GetMulticastGroupId() uint32

func (*MulticastGroupEntry) GetReplicas 

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

func (*MulticastGroupEntry) ProtoMessage 

func (*MulticastGroupEntry) ProtoMessage()

func (*MulticastGroupEntry) Reset 

func (m *MulticastGroupEntry) Reset()

func (*MulticastGroupEntry) String 

func (m *MulticastGroupEntry) String() string

func (*MulticastGroupEntry) XXX_DiscardUnknown 

func (m *MulticastGroupEntry) XXX_DiscardUnknown()

func (*MulticastGroupEntry) XXX_Marshal 

func (m *MulticastGroupEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MulticastGroupEntry) XXX_Merge 

func (m *MulticastGroupEntry) XXX_Merge(src proto.Message)

func (*MulticastGroupEntry) XXX_Size 

func (m *MulticastGroupEntry) XXX_Size() int

func (*MulticastGroupEntry) XXX_Unmarshal 

func (m *MulticastGroupEntry) XXX_Unmarshal(b []byte) error

type P4Data 

type P4Data struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*P4Data) Descriptor 

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

func (*P4Data) GetBitstring 

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

func (*P4Data) GetBool 

func (m *P4Data) GetBool() bool

func (*P4Data) GetData 

func (m *P4Data) GetData() isP4Data_Data

func (*P4Data) GetEnum 

func (m *P4Data) GetEnum() string

func (*P4Data) GetEnumValue 

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

func (*P4Data) GetError 

func (m *P4Data) GetError() string

func (*P4Data) GetHeader 

func (m *P4Data) GetHeader() *P4Header

func (*P4Data) GetHeaderStack 

func (m *P4Data) GetHeaderStack() *P4HeaderStack

func (*P4Data) GetHeaderUnion 

func (m *P4Data) GetHeaderUnion() *P4HeaderUnion

func (*P4Data) GetHeaderUnionStack 

func (m *P4Data) GetHeaderUnionStack() *P4HeaderUnionStack

func (*P4Data) GetStruct 

func (m *P4Data) GetStruct() *P4StructLike

func (*P4Data) GetTuple 

func (m *P4Data) GetTuple() *P4StructLike

func (*P4Data) GetVarbit 

func (m *P4Data) GetVarbit() *P4Varbit

func (*P4Data) ProtoMessage 

func (*P4Data) ProtoMessage()

func (*P4Data) Reset 

func (m *P4Data) Reset()

func (*P4Data) String 

func (m *P4Data) String() string

func (*P4Data) XXX_DiscardUnknown 

func (m *P4Data) XXX_DiscardUnknown()

func (*P4Data) XXX_Marshal 

func (m *P4Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4Data) XXX_Merge 

func (m *P4Data) XXX_Merge(src proto.Message)

func (*P4Data) XXX_OneofWrappers 

func (*P4Data) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*P4Data) XXX_Size 

func (m *P4Data) XXX_Size() int

func (*P4Data) XXX_Unmarshal 

func (m *P4Data) XXX_Unmarshal(b []byte) error

type P4Data_Bitstring 

type P4Data_Bitstring struct {
	Bitstring []byte `protobuf:"bytes,1,opt,name=bitstring,proto3,oneof"`
}

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"`
}

type P4Data_EnumValue 

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

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"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*P4Header) Descriptor 

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

func (*P4Header) GetBitstrings 

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

func (*P4Header) GetIsValid 

func (m *P4Header) GetIsValid() bool

func (*P4Header) ProtoMessage 

func (*P4Header) ProtoMessage()

func (*P4Header) Reset 

func (m *P4Header) Reset()

func (*P4Header) String 

func (m *P4Header) String() string

func (*P4Header) XXX_DiscardUnknown 

func (m *P4Header) XXX_DiscardUnknown()

func (*P4Header) XXX_Marshal 

func (m *P4Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4Header) XXX_Merge 

func (m *P4Header) XXX_Merge(src proto.Message)

func (*P4Header) XXX_Size 

func (m *P4Header) XXX_Size() int

func (*P4Header) XXX_Unmarshal 

func (m *P4Header) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*P4HeaderStack) Descriptor 

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

func (*P4HeaderStack) GetEntries 

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

func (*P4HeaderStack) ProtoMessage 

func (*P4HeaderStack) ProtoMessage()

func (*P4HeaderStack) Reset 

func (m *P4HeaderStack) Reset()

func (*P4HeaderStack) String 

func (m *P4HeaderStack) String() string

func (*P4HeaderStack) XXX_DiscardUnknown 

func (m *P4HeaderStack) XXX_DiscardUnknown()

func (*P4HeaderStack) XXX_Marshal 

func (m *P4HeaderStack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4HeaderStack) XXX_Merge 

func (m *P4HeaderStack) XXX_Merge(src proto.Message)

func (*P4HeaderStack) XXX_Size 

func (m *P4HeaderStack) XXX_Size() int

func (*P4HeaderStack) XXX_Unmarshal 

func (m *P4HeaderStack) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*P4HeaderUnion) Descriptor 

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

func (*P4HeaderUnion) GetValidHeader 

func (m *P4HeaderUnion) GetValidHeader() *P4Header

func (*P4HeaderUnion) GetValidHeaderName 

func (m *P4HeaderUnion) GetValidHeaderName() string

func (*P4HeaderUnion) ProtoMessage 

func (*P4HeaderUnion) ProtoMessage()

func (*P4HeaderUnion) Reset 

func (m *P4HeaderUnion) Reset()

func (*P4HeaderUnion) String 

func (m *P4HeaderUnion) String() string

func (*P4HeaderUnion) XXX_DiscardUnknown 

func (m *P4HeaderUnion) XXX_DiscardUnknown()

func (*P4HeaderUnion) XXX_Marshal 

func (m *P4HeaderUnion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4HeaderUnion) XXX_Merge 

func (m *P4HeaderUnion) XXX_Merge(src proto.Message)

func (*P4HeaderUnion) XXX_Size 

func (m *P4HeaderUnion) XXX_Size() int

func (*P4HeaderUnion) XXX_Unmarshal 

func (m *P4HeaderUnion) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*P4HeaderUnionStack) Descriptor 

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

func (*P4HeaderUnionStack) GetEntries 

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

func (*P4HeaderUnionStack) ProtoMessage 

func (*P4HeaderUnionStack) ProtoMessage()

func (*P4HeaderUnionStack) Reset 

func (m *P4HeaderUnionStack) Reset()

func (*P4HeaderUnionStack) String 

func (m *P4HeaderUnionStack) String() string

func (*P4HeaderUnionStack) XXX_DiscardUnknown 

func (m *P4HeaderUnionStack) XXX_DiscardUnknown()

func (*P4HeaderUnionStack) XXX_Marshal 

func (m *P4HeaderUnionStack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4HeaderUnionStack) XXX_Merge 

func (m *P4HeaderUnionStack) XXX_Merge(src proto.Message)

func (*P4HeaderUnionStack) XXX_Size 

func (m *P4HeaderUnionStack) XXX_Size() int

func (*P4HeaderUnionStack) XXX_Unmarshal 

func (m *P4HeaderUnionStack) XXX_Unmarshal(b []byte) error

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 master arbitration
	// - indicating switch session liveness: the session is live when switch
	//   sends a positive master arbitration update to the controller, and is
	//   considered dead when either the stream breaks or the switch sends a
	//   negative update for master 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)
}

P4RuntimeClient is the client API for P4Runtime service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewP4RuntimeClient 

func NewP4RuntimeClient(cc *grpc.ClientConn) 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 master arbitration
	// - indicating switch session liveness: the session is live when switch
	//   sends a positive master arbitration update to the controller, and is
	//   considered dead when either the stream breaks or the switch sends a
	//   negative update for master arbitration
	// - the controller sending/receiving packets to/from the switch
	// - streaming of notifications from the switch
	StreamChannel(P4Runtime_StreamChannelServer) error
}

P4RuntimeServer is the server API for P4Runtime service.

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*P4StructLike) Descriptor 

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

func (*P4StructLike) GetMembers 

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

func (*P4StructLike) ProtoMessage 

func (*P4StructLike) ProtoMessage()

func (*P4StructLike) Reset 

func (m *P4StructLike) Reset()

func (*P4StructLike) String 

func (m *P4StructLike) String() string

func (*P4StructLike) XXX_DiscardUnknown 

func (m *P4StructLike) XXX_DiscardUnknown()

func (*P4StructLike) XXX_Marshal 

func (m *P4StructLike) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4StructLike) XXX_Merge 

func (m *P4StructLike) XXX_Merge(src proto.Message)

func (*P4StructLike) XXX_Size 

func (m *P4StructLike) XXX_Size() int

func (*P4StructLike) XXX_Unmarshal 

func (m *P4StructLike) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*P4Varbit) Descriptor 

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

func (*P4Varbit) GetBitstring 

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

func (*P4Varbit) GetBitwidth 

func (m *P4Varbit) GetBitwidth() int32

func (*P4Varbit) ProtoMessage 

func (*P4Varbit) ProtoMessage()

func (*P4Varbit) Reset 

func (m *P4Varbit) Reset()

func (*P4Varbit) String 

func (m *P4Varbit) String() string

func (*P4Varbit) XXX_DiscardUnknown 

func (m *P4Varbit) XXX_DiscardUnknown()

func (*P4Varbit) XXX_Marshal 

func (m *P4Varbit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*P4Varbit) XXX_Merge 

func (m *P4Varbit) XXX_Merge(src proto.Message)

func (*P4Varbit) XXX_Size 

func (m *P4Varbit) XXX_Size() int

func (*P4Varbit) XXX_Unmarshal 

func (m *P4Varbit) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Packet sent from the switch to the controller.

func (*PacketIn) Descriptor 

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

func (*PacketIn) GetMetadata 

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

func (*PacketIn) GetPayload 

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

func (*PacketIn) ProtoMessage 

func (*PacketIn) ProtoMessage()

func (*PacketIn) Reset 

func (m *PacketIn) Reset()

func (*PacketIn) String 

func (m *PacketIn) String() string

func (*PacketIn) XXX_DiscardUnknown 

func (m *PacketIn) XXX_DiscardUnknown()

func (*PacketIn) XXX_Marshal 

func (m *PacketIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketIn) XXX_Merge 

func (m *PacketIn) XXX_Merge(src proto.Message)

func (*PacketIn) XXX_Size 

func (m *PacketIn) XXX_Size() int

func (*PacketIn) XXX_Unmarshal 

func (m *PacketIn) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*PacketMetadata) GetMetadataId 

func (m *PacketMetadata) GetMetadataId() uint32

func (*PacketMetadata) GetValue 

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

func (*PacketMetadata) ProtoMessage 

func (*PacketMetadata) ProtoMessage()

func (*PacketMetadata) Reset 

func (m *PacketMetadata) Reset()

func (*PacketMetadata) String 

func (m *PacketMetadata) String() string

func (*PacketMetadata) XXX_DiscardUnknown 

func (m *PacketMetadata) XXX_DiscardUnknown()

func (*PacketMetadata) XXX_Marshal 

func (m *PacketMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketMetadata) XXX_Merge 

func (m *PacketMetadata) XXX_Merge(src proto.Message)

func (*PacketMetadata) XXX_Size 

func (m *PacketMetadata) XXX_Size() int

func (*PacketMetadata) XXX_Unmarshal 

func (m *PacketMetadata) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Packet sent from the controller to the switch.

func (*PacketOut) Descriptor 

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

func (*PacketOut) GetMetadata 

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

func (*PacketOut) GetPayload 

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

func (*PacketOut) ProtoMessage 

func (*PacketOut) ProtoMessage()

func (*PacketOut) Reset 

func (m *PacketOut) Reset()

func (*PacketOut) String 

func (m *PacketOut) String() string

func (*PacketOut) XXX_DiscardUnknown 

func (m *PacketOut) XXX_DiscardUnknown()

func (*PacketOut) XXX_Marshal 

func (m *PacketOut) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketOut) XXX_Merge 

func (m *PacketOut) XXX_Merge(src proto.Message)

func (*PacketOut) XXX_Size 

func (m *PacketOut) XXX_Size() int

func (*PacketOut) XXX_Unmarshal 

func (m *PacketOut) XXX_Unmarshal(b []byte) error

type PacketReplicationEngineEntry 

type PacketReplicationEngineEntry struct {
	// Types that are valid to be assigned to Type:
	//	*PacketReplicationEngineEntry_MulticastGroupEntry
	//	*PacketReplicationEngineEntry_CloneSessionEntry
	Type                 isPacketReplicationEngineEntry_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*PacketReplicationEngineEntry) GetCloneSessionEntry 

func (m *PacketReplicationEngineEntry) GetCloneSessionEntry() *CloneSessionEntry

func (*PacketReplicationEngineEntry) GetMulticastGroupEntry 

func (m *PacketReplicationEngineEntry) GetMulticastGroupEntry() *MulticastGroupEntry

func (*PacketReplicationEngineEntry) GetType 

func (m *PacketReplicationEngineEntry) GetType() isPacketReplicationEngineEntry_Type

func (*PacketReplicationEngineEntry) ProtoMessage 

func (*PacketReplicationEngineEntry) ProtoMessage()

func (*PacketReplicationEngineEntry) Reset 

func (m *PacketReplicationEngineEntry) Reset()

func (*PacketReplicationEngineEntry) String 

func (m *PacketReplicationEngineEntry) String() string

func (*PacketReplicationEngineEntry) XXX_DiscardUnknown 

func (m *PacketReplicationEngineEntry) XXX_DiscardUnknown()

func (*PacketReplicationEngineEntry) XXX_Marshal 

func (m *PacketReplicationEngineEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketReplicationEngineEntry) XXX_Merge 

func (m *PacketReplicationEngineEntry) XXX_Merge(src proto.Message)

func (*PacketReplicationEngineEntry) XXX_OneofWrappers 

func (*PacketReplicationEngineEntry) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PacketReplicationEngineEntry) XXX_Size 

func (m *PacketReplicationEngineEntry) XXX_Size() int

func (*PacketReplicationEngineEntry) XXX_Unmarshal 

func (m *PacketReplicationEngineEntry) XXX_Unmarshal(b []byte) error

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"`
	Entities             []*Entity `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetDeviceId 

func (m *ReadRequest) GetDeviceId() uint64

func (*ReadRequest) GetEntities 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge 

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

type ReadResponse 

type ReadResponse struct {
	Entities             []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetEntities 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadResponse) XXX_Merge 

func (m *ReadResponse) XXX_Merge(src proto.Message)

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

func (m *ReadResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterEntry) Descriptor 

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

func (*RegisterEntry) GetData 

func (m *RegisterEntry) GetData() *P4Data

func (*RegisterEntry) GetIndex 

func (m *RegisterEntry) GetIndex() *Index

func (*RegisterEntry) GetRegisterId 

func (m *RegisterEntry) GetRegisterId() uint32

func (*RegisterEntry) ProtoMessage 

func (*RegisterEntry) ProtoMessage()

func (*RegisterEntry) Reset 

func (m *RegisterEntry) Reset()

func (*RegisterEntry) String 

func (m *RegisterEntry) String() string

func (*RegisterEntry) XXX_DiscardUnknown 

func (m *RegisterEntry) XXX_DiscardUnknown()

func (*RegisterEntry) XXX_Marshal 

func (m *RegisterEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterEntry) XXX_Merge 

func (m *RegisterEntry) XXX_Merge(src proto.Message)

func (*RegisterEntry) XXX_Size 

func (m *RegisterEntry) XXX_Size() int

func (*RegisterEntry) XXX_Unmarshal 

func (m *RegisterEntry) XXX_Unmarshal(b []byte) error

type Replica 

type Replica struct {
	EgressPort           uint32   `protobuf:"varint,1,opt,name=egress_port,json=egressPort,proto3" json:"egress_port,omitempty"`
	Instance             uint32   `protobuf:"varint,2,opt,name=instance,proto3" json:"instance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Used for replicas created for cloning and multicasting actions.

func (*Replica) Descriptor 

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

func (*Replica) GetEgressPort 

func (m *Replica) GetEgressPort() uint32

func (*Replica) GetInstance 

func (m *Replica) GetInstance() uint32

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

func (m *Replica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Replica) XXX_Merge 

func (m *Replica) XXX_Merge(src proto.Message)

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

func (m *Replica) XXX_Unmarshal(b []byte) error

type Role 

type Role struct {
	// Uniquely identifies this role.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,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               *any.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Role) Descriptor 

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

func (*Role) GetConfig 

func (m *Role) GetConfig() *any.Any

func (*Role) GetId 

func (m *Role) GetId() uint64

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) Reset 

func (m *Role) Reset()

func (*Role) String 

func (m *Role) String() string

func (*Role) XXX_DiscardUnknown 

func (m *Role) XXX_DiscardUnknown()

func (*Role) XXX_Marshal 

func (m *Role) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Role) XXX_Merge 

func (m *Role) XXX_Merge(src proto.Message)

func (*Role) XXX_Size 

func (m *Role) XXX_Size() int

func (*Role) XXX_Unmarshal 

func (m *Role) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (SdnPort) String 

func (x SdnPort) String() string

type SetForwardingPipelineConfigRequest 

type SetForwardingPipelineConfigRequest struct {
	DeviceId             uint64                                    `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	RoleId               uint64                                    `protobuf:"varint,2,opt,name=role_id,json=roleId,proto3" json:"role_id,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"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

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

func (*SetForwardingPipelineConfigRequest) Descriptor 

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

func (*SetForwardingPipelineConfigRequest) GetAction 

func (m *SetForwardingPipelineConfigRequest) GetAction() SetForwardingPipelineConfigRequest_Action

func (*SetForwardingPipelineConfigRequest) GetConfig 

func (m *SetForwardingPipelineConfigRequest) GetConfig() *ForwardingPipelineConfig

func (*SetForwardingPipelineConfigRequest) GetDeviceId 

func (m *SetForwardingPipelineConfigRequest) GetDeviceId() uint64

func (*SetForwardingPipelineConfigRequest) GetElectionId 

func (m *SetForwardingPipelineConfigRequest) GetElectionId() *Uint128

func (*SetForwardingPipelineConfigRequest) GetRoleId 

func (m *SetForwardingPipelineConfigRequest) GetRoleId() uint64

func (*SetForwardingPipelineConfigRequest) ProtoMessage 

func (*SetForwardingPipelineConfigRequest) ProtoMessage()

func (*SetForwardingPipelineConfigRequest) Reset 

func (m *SetForwardingPipelineConfigRequest) Reset()

func (*SetForwardingPipelineConfigRequest) String 

func (m *SetForwardingPipelineConfigRequest) String() string

func (*SetForwardingPipelineConfigRequest) XXX_DiscardUnknown 

func (m *SetForwardingPipelineConfigRequest) XXX_DiscardUnknown()

func (*SetForwardingPipelineConfigRequest) XXX_Marshal 

func (m *SetForwardingPipelineConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetForwardingPipelineConfigRequest) XXX_Merge 

func (m *SetForwardingPipelineConfigRequest) XXX_Merge(src proto.Message)

func (*SetForwardingPipelineConfigRequest) XXX_Size 

func (m *SetForwardingPipelineConfigRequest) XXX_Size() int

func (*SetForwardingPipelineConfigRequest) XXX_Unmarshal 

func (m *SetForwardingPipelineConfigRequest) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (SetForwardingPipelineConfigRequest_Action) String 

func (x SetForwardingPipelineConfigRequest_Action) String() string

type SetForwardingPipelineConfigResponse 

type SetForwardingPipelineConfigResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetForwardingPipelineConfigResponse) Descriptor 

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

func (*SetForwardingPipelineConfigResponse) ProtoMessage 

func (*SetForwardingPipelineConfigResponse) ProtoMessage()

func (*SetForwardingPipelineConfigResponse) Reset 

func (m *SetForwardingPipelineConfigResponse) Reset()

func (*SetForwardingPipelineConfigResponse) String 

func (m *SetForwardingPipelineConfigResponse) String() string

func (*SetForwardingPipelineConfigResponse) XXX_DiscardUnknown 

func (m *SetForwardingPipelineConfigResponse) XXX_DiscardUnknown()

func (*SetForwardingPipelineConfigResponse) XXX_Marshal 

func (m *SetForwardingPipelineConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetForwardingPipelineConfigResponse) XXX_Merge 

func (m *SetForwardingPipelineConfigResponse) XXX_Merge(src proto.Message)

func (*SetForwardingPipelineConfigResponse) XXX_Size 

func (m *SetForwardingPipelineConfigResponse) XXX_Size() int

func (*SetForwardingPipelineConfigResponse) XXX_Unmarshal 

func (m *SetForwardingPipelineConfigResponse) XXX_Unmarshal(b []byte) error

type StreamMessageRequest 

type StreamMessageRequest struct {
	// Types that are valid to be assigned to Update:
	//	*StreamMessageRequest_Arbitration
	//	*StreamMessageRequest_Packet
	//	*StreamMessageRequest_DigestAck
	//	*StreamMessageRequest_Other
	Update               isStreamMessageRequest_Update `protobuf_oneof:"update"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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

func (*StreamMessageRequest) Descriptor 

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

func (*StreamMessageRequest) GetArbitration 

func (m *StreamMessageRequest) GetArbitration() *MasterArbitrationUpdate

func (*StreamMessageRequest) GetDigestAck 

func (m *StreamMessageRequest) GetDigestAck() *DigestListAck

func (*StreamMessageRequest) GetOther 

func (m *StreamMessageRequest) GetOther() *any.Any

func (*StreamMessageRequest) GetPacket 

func (m *StreamMessageRequest) GetPacket() *PacketOut

func (*StreamMessageRequest) GetUpdate 

func (m *StreamMessageRequest) GetUpdate() isStreamMessageRequest_Update

func (*StreamMessageRequest) ProtoMessage 

func (*StreamMessageRequest) ProtoMessage()

func (*StreamMessageRequest) Reset 

func (m *StreamMessageRequest) Reset()

func (*StreamMessageRequest) String 

func (m *StreamMessageRequest) String() string

func (*StreamMessageRequest) XXX_DiscardUnknown 

func (m *StreamMessageRequest) XXX_DiscardUnknown()

func (*StreamMessageRequest) XXX_Marshal 

func (m *StreamMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMessageRequest) XXX_Merge 

func (m *StreamMessageRequest) XXX_Merge(src proto.Message)

func (*StreamMessageRequest) XXX_OneofWrappers 

func (*StreamMessageRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamMessageRequest) XXX_Size 

func (m *StreamMessageRequest) XXX_Size() int

func (*StreamMessageRequest) XXX_Unmarshal 

func (m *StreamMessageRequest) XXX_Unmarshal(b []byte) error

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 *any.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 valid to be assigned to Update:
	//	*StreamMessageResponse_Arbitration
	//	*StreamMessageResponse_Packet
	//	*StreamMessageResponse_Digest
	//	*StreamMessageResponse_IdleTimeoutNotification
	//	*StreamMessageResponse_Other
	Update               isStreamMessageResponse_Update `protobuf_oneof:"update"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*StreamMessageResponse) Descriptor 

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

func (*StreamMessageResponse) GetArbitration 

func (m *StreamMessageResponse) GetArbitration() *MasterArbitrationUpdate

func (*StreamMessageResponse) GetDigest 

func (m *StreamMessageResponse) GetDigest() *DigestList

func (*StreamMessageResponse) GetIdleTimeoutNotification 

func (m *StreamMessageResponse) GetIdleTimeoutNotification() *IdleTimeoutNotification

func (*StreamMessageResponse) GetOther 

func (m *StreamMessageResponse) GetOther() *any.Any

func (*StreamMessageResponse) GetPacket 

func (m *StreamMessageResponse) GetPacket() *PacketIn

func (*StreamMessageResponse) GetUpdate 

func (m *StreamMessageResponse) GetUpdate() isStreamMessageResponse_Update

func (*StreamMessageResponse) ProtoMessage 

func (*StreamMessageResponse) ProtoMessage()

func (*StreamMessageResponse) Reset 

func (m *StreamMessageResponse) Reset()

func (*StreamMessageResponse) String 

func (m *StreamMessageResponse) String() string

func (*StreamMessageResponse) XXX_DiscardUnknown 

func (m *StreamMessageResponse) XXX_DiscardUnknown()

func (*StreamMessageResponse) XXX_Marshal 

func (m *StreamMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMessageResponse) XXX_Merge 

func (m *StreamMessageResponse) XXX_Merge(src proto.Message)

func (*StreamMessageResponse) XXX_OneofWrappers 

func (*StreamMessageResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamMessageResponse) XXX_Size 

func (m *StreamMessageResponse) XXX_Size() int

func (*StreamMessageResponse) XXX_Unmarshal 

func (m *StreamMessageResponse) XXX_Unmarshal(b []byte) error

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_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 *any.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 TableAction 

type TableAction struct {
	// Types that are valid to be assigned to Type:
	//	*TableAction_Action
	//	*TableAction_ActionProfileMemberId
	//	*TableAction_ActionProfileGroupId
	//	*TableAction_ActionProfileActionSet
	Type                 isTableAction_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

table_actions ::= action_specification | action_profile_specification

func (*TableAction) Descriptor 

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

func (*TableAction) GetAction 

func (m *TableAction) GetAction() *Action

func (*TableAction) GetActionProfileActionSet 

func (m *TableAction) GetActionProfileActionSet() *ActionProfileActionSet

func (*TableAction) GetActionProfileGroupId 

func (m *TableAction) GetActionProfileGroupId() uint32

func (*TableAction) GetActionProfileMemberId 

func (m *TableAction) GetActionProfileMemberId() uint32

func (*TableAction) GetType 

func (m *TableAction) GetType() isTableAction_Type

func (*TableAction) ProtoMessage 

func (*TableAction) ProtoMessage()

func (*TableAction) Reset 

func (m *TableAction) Reset()

func (*TableAction) String 

func (m *TableAction) String() string

func (*TableAction) XXX_DiscardUnknown 

func (m *TableAction) XXX_DiscardUnknown()

func (*TableAction) XXX_Marshal 

func (m *TableAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableAction) XXX_Merge 

func (m *TableAction) XXX_Merge(src proto.Message)

func (*TableAction) XXX_OneofWrappers 

func (*TableAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TableAction) XXX_Size 

func (m *TableAction) XXX_Size() int

func (*TableAction) XXX_Unmarshal 

func (m *TableAction) XXX_Unmarshal(b []byte) error

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 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.
	ControllerMetadata uint64 `protobuf:"varint,5,opt,name=controller_metadata,json=controllerMetadata,proto3" json:"controller_metadata,omitempty"`
	// meter_config and 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
	//     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 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"`
	// 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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*TableEntry) Descriptor 

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

func (*TableEntry) GetAction 

func (m *TableEntry) GetAction() *TableAction

func (*TableEntry) GetControllerMetadata 

func (m *TableEntry) GetControllerMetadata() uint64

func (*TableEntry) GetCounterData 

func (m *TableEntry) GetCounterData() *CounterData

func (*TableEntry) GetIdleTimeoutNs 

func (m *TableEntry) GetIdleTimeoutNs() int64

func (*TableEntry) GetIsDefaultAction 

func (m *TableEntry) GetIsDefaultAction() bool

func (*TableEntry) GetMatch 

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

func (*TableEntry) GetMeterConfig 

func (m *TableEntry) GetMeterConfig() *MeterConfig

func (*TableEntry) GetPriority 

func (m *TableEntry) GetPriority() int32

func (*TableEntry) GetTableId 

func (m *TableEntry) GetTableId() uint32

func (*TableEntry) GetTimeSinceLastHit 

func (m *TableEntry) GetTimeSinceLastHit() *TableEntry_IdleTimeout

func (*TableEntry) ProtoMessage 

func (*TableEntry) ProtoMessage()

func (*TableEntry) Reset 

func (m *TableEntry) Reset()

func (*TableEntry) String 

func (m *TableEntry) String() string

func (*TableEntry) XXX_DiscardUnknown 

func (m *TableEntry) XXX_DiscardUnknown()

func (*TableEntry) XXX_Marshal 

func (m *TableEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableEntry) XXX_Merge 

func (m *TableEntry) XXX_Merge(src proto.Message)

func (*TableEntry) XXX_Size 

func (m *TableEntry) XXX_Size() int

func (*TableEntry) XXX_Unmarshal 

func (m *TableEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableEntry_IdleTimeout) Descriptor 

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

func (*TableEntry_IdleTimeout) GetElapsedNs 

func (m *TableEntry_IdleTimeout) GetElapsedNs() int64

func (*TableEntry_IdleTimeout) ProtoMessage 

func (*TableEntry_IdleTimeout) ProtoMessage()

func (*TableEntry_IdleTimeout) Reset 

func (m *TableEntry_IdleTimeout) Reset()

func (*TableEntry_IdleTimeout) String 

func (m *TableEntry_IdleTimeout) String() string

func (*TableEntry_IdleTimeout) XXX_DiscardUnknown 

func (m *TableEntry_IdleTimeout) XXX_DiscardUnknown()

func (*TableEntry_IdleTimeout) XXX_Marshal 

func (m *TableEntry_IdleTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableEntry_IdleTimeout) XXX_Merge 

func (m *TableEntry_IdleTimeout) XXX_Merge(src proto.Message)

func (*TableEntry_IdleTimeout) XXX_Size 

func (m *TableEntry_IdleTimeout) XXX_Size() int

func (*TableEntry_IdleTimeout) XXX_Unmarshal 

func (m *TableEntry_IdleTimeout) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Uint128) Descriptor 

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

func (*Uint128) GetHigh 

func (m *Uint128) GetHigh() uint64

func (*Uint128) GetLow 

func (m *Uint128) GetLow() uint64

func (*Uint128) ProtoMessage 

func (*Uint128) ProtoMessage()

func (*Uint128) Reset 

func (m *Uint128) Reset()

func (*Uint128) String 

func (m *Uint128) String() string

func (*Uint128) XXX_DiscardUnknown 

func (m *Uint128) XXX_DiscardUnknown()

func (*Uint128) XXX_Marshal 

func (m *Uint128) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Uint128) XXX_Merge 

func (m *Uint128) XXX_Merge(src proto.Message)

func (*Uint128) XXX_Size 

func (m *Uint128) XXX_Size() int

func (*Uint128) XXX_Unmarshal 

func (m *Uint128) XXX_Unmarshal(b []byte) error

type UnimplementedP4RuntimeServer 

type UnimplementedP4RuntimeServer struct {
}

UnimplementedP4RuntimeServer can be embedded to have forward compatible implementations.

func (*UnimplementedP4RuntimeServer) GetForwardingPipelineConfig 

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

func (*UnimplementedP4RuntimeServer) Read 

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

func (*UnimplementedP4RuntimeServer) SetForwardingPipelineConfig 

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

func (*UnimplementedP4RuntimeServer) StreamChannel 

func (*UnimplementedP4RuntimeServer) StreamChannel(srv P4Runtime_StreamChannelServer) error

func (*UnimplementedP4RuntimeServer) Write 

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

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Update) Descriptor 

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

func (*Update) GetEntity 

func (m *Update) GetEntity() *Entity

func (*Update) GetType 

func (m *Update) GetType() Update_Type

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) String 

func (m *Update) String() string

func (*Update) XXX_DiscardUnknown 

func (m *Update) XXX_DiscardUnknown()

func (*Update) XXX_Marshal 

func (m *Update) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Update) XXX_Merge 

func (m *Update) XXX_Merge(src proto.Message)

func (*Update) XXX_Size 

func (m *Update) XXX_Size() int

func (*Update) XXX_Unmarshal 

func (m *Update) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (Update_Type) String 

func (x Update_Type) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

------------------------------------------------------------------------------ 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 

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

func (*ValueSetEntry) GetMembers 

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

func (*ValueSetEntry) GetValueSetId 

func (m *ValueSetEntry) GetValueSetId() uint32

func (*ValueSetEntry) ProtoMessage 

func (*ValueSetEntry) ProtoMessage()

func (*ValueSetEntry) Reset 

func (m *ValueSetEntry) Reset()

func (*ValueSetEntry) String 

func (m *ValueSetEntry) String() string

func (*ValueSetEntry) XXX_DiscardUnknown 

func (m *ValueSetEntry) XXX_DiscardUnknown()

func (*ValueSetEntry) XXX_Marshal 

func (m *ValueSetEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueSetEntry) XXX_Merge 

func (m *ValueSetEntry) XXX_Merge(src proto.Message)

func (*ValueSetEntry) XXX_Size 

func (m *ValueSetEntry) XXX_Size() int

func (*ValueSetEntry) XXX_Unmarshal 

func (m *ValueSetEntry) XXX_Unmarshal(b []byte) error

type ValueSetMember 

type ValueSetMember struct {
	Match                []*FieldMatch `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

func (*ValueSetMember) Descriptor 

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

func (*ValueSetMember) GetMatch 

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

func (*ValueSetMember) ProtoMessage 

func (*ValueSetMember) ProtoMessage()

func (*ValueSetMember) Reset 

func (m *ValueSetMember) Reset()

func (*ValueSetMember) String 

func (m *ValueSetMember) String() string

func (*ValueSetMember) XXX_DiscardUnknown 

func (m *ValueSetMember) XXX_DiscardUnknown()

func (*ValueSetMember) XXX_Marshal 

func (m *ValueSetMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueSetMember) XXX_Merge 

func (m *ValueSetMember) XXX_Merge(src proto.Message)

func (*ValueSetMember) XXX_Size 

func (m *ValueSetMember) XXX_Size() int

func (*ValueSetMember) XXX_Unmarshal 

func (m *ValueSetMember) XXX_Unmarshal(b []byte) error

type WriteRequest 

type WriteRequest struct {
	DeviceId   uint64   `protobuf:"varint,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	RoleId     uint64   `protobuf:"varint,2,opt,name=role_id,json=roleId,proto3" json:"role_id,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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

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

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetAtomicity 

func (m *WriteRequest) GetAtomicity() WriteRequest_Atomicity

func (*WriteRequest) GetDeviceId 

func (m *WriteRequest) GetDeviceId() uint64

func (*WriteRequest) GetElectionId 

func (m *WriteRequest) GetElectionId() *Uint128

func (*WriteRequest) GetRoleId 

func (m *WriteRequest) GetRoleId() uint64

func (*WriteRequest) GetUpdates 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge 

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (WriteRequest_Atomicity) String 

func (x WriteRequest_Atomicity) String() string

type WriteResponse 

type WriteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteResponse) XXX_Merge 

func (m *WriteResponse) XXX_Merge(src proto.Message)

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

func (m *WriteResponse) XXX_Unmarshal(b []byte) error

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.