_go

package
v0.0.0-...-8b07b99 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IpVersion_name = map[int32]string{
		0: "_IPV4",
		1: "_IPV6",
	}
	IpVersion_value = map[string]int32{
		"_IPV4": 0,
		"_IPV6": 1,
	}
)

Enum value maps for IpVersion.

View Source 
var (
	ProtocolId_name = map[int32]string{
		0:  "_HOPOPT",
		6:  "_TCP",
		17: "_UDP",
	}
	ProtocolId_value = map[string]int32{
		"_HOPOPT": 0,
		"_TCP":    6,
		"_UDP":    17,
	}
)

Enum value maps for ProtocolId.

View Source 
var (
	SessionState_name = map[int32]string{
		0: "_ESTABLISHED",
		1: "_CLOSING_1",
		2: "_CLOSING_2",
		3: "_CLOSED",
		4: "_UNKNOWN_STATE",
	}
	SessionState_value = map[string]int32{
		"_ESTABLISHED":   0,
		"_CLOSING_1":     1,
		"_CLOSING_2":     2,
		"_CLOSED":        3,
		"_UNKNOWN_STATE": 4,
	}
)

Enum value maps for SessionState.

View Source 
var (
	SessionCloseCode_name = map[int32]string{
		0: "_NOT_CLOSED",
		1: "_FINACK",
		2: "_RST",
		3: "_TIMEOUT",
		4: "_UNKNOWN_CLOSE_CODE",
	}
	SessionCloseCode_value = map[string]int32{
		"_NOT_CLOSED":         0,
		"_FINACK":             1,
		"_RST":                2,
		"_TIMEOUT":            3,
		"_UNKNOWN_CLOSE_CODE": 4,
	}
)

Enum value maps for SessionCloseCode.

View Source 
var (
	AddSessionStatus_name = map[int32]string{
		0: "_SESSION_ACCEPTED",
		1: "_SESSION_REJECTED",
		2: "_SESSION_TABLE_FULL",
		3: "_SESSION_TABLE_UNAVAILABLE",
		4: "_SESSION_ALREADY_EXISTS",
	}
	AddSessionStatus_value = map[string]int32{
		"_SESSION_ACCEPTED":          0,
		"_SESSION_REJECTED":          1,
		"_SESSION_TABLE_FULL":        2,
		"_SESSION_TABLE_UNAVAILABLE": 3,
		"_SESSION_ALREADY_EXISTS":    4,
	}
)

Enum value maps for AddSessionStatus.

View Source 
var (
	RequestStatus_name = map[int32]string{
		0: "_ACCEPTED",
		1: "_REJECTED",
		2: "_REJECTED_SESSION_NONEXISTENT",
		3: "_REJECTED_SESSION_TABLE_FULL",
		4: "_REJECTED_SESSION_ALREADY_EXISTS",
		5: "_NO_CLOSED_SESSIONS",
		6: "_REJECTED_INTERNAL_ERROR",
	}
	RequestStatus_value = map[string]int32{
		"_ACCEPTED":                        0,
		"_REJECTED":                        1,
		"_REJECTED_SESSION_NONEXISTENT":    2,
		"_REJECTED_SESSION_TABLE_FULL":     3,
		"_REJECTED_SESSION_ALREADY_EXISTS": 4,
		"_NO_CLOSED_SESSIONS":              5,
		"_REJECTED_INTERNAL_ERROR":         6,
	}
)

Enum value maps for RequestStatus.

View Source 
var (
	ActionType_name = map[int32]string{
		0: "_DROP",
		1: "_FORWARD",
		2: "_MIRROR",
		3: "_SNOOP",
	}
	ActionType_value = map[string]int32{
		"_DROP":    0,
		"_FORWARD": 1,
		"_MIRROR":  2,
		"_SNOOP":   3,
	}
)

Enum value maps for ActionType.

View Source 
var (
	AddTunnelStatus_name = map[int32]string{
		0: "_TUNNEL_ACCEPTED",
		1: "_TUNNEL_REJECTED",
		2: "_TUNNEL_TABLE_FULL",
		3: "_TUNNEL_TABLE_UNAVAILABLE",
		4: "_TUNNEL_ALREADY_EXISTS",
	}
	AddTunnelStatus_value = map[string]int32{
		"_TUNNEL_ACCEPTED":          0,
		"_TUNNEL_REJECTED":          1,
		"_TUNNEL_TABLE_FULL":        2,
		"_TUNNEL_TABLE_UNAVAILABLE": 3,
		"_TUNNEL_ALREADY_EXISTS":    4,
	}
)

Enum value maps for AddTunnelStatus.

View Source 
var (
	Operation_name = map[int32]string{
		0: "_NONE",
		1: "_CREATE",
		2: "_UPDATE",
		3: "_DELETE",
	}
	Operation_value = map[string]int32{
		"_NONE":   0,
		"_CREATE": 1,
		"_UPDATE": 2,
		"_DELETE": 3,
	}
)

Enum value maps for Operation.

View Source 
var (
	EncType_name = map[int32]string{
		0:  "_AES256GCM64",
		1:  "_AES256GCM96",
		2:  "_AES256GCM128",
		3:  "_AES128GCM64",
		4:  "_AES128GCM96",
		5:  "_AES128GCM128",
		6:  "_AES256CCM64",
		7:  "_AES256CCM96",
		8:  "_AES256CCM128",
		9:  "_AES128CCM64",
		10: "_AES128CCM96",
		11: "_AES128CCM128",
	}
	EncType_value = map[string]int32{
		"_AES256GCM64":  0,
		"_AES256GCM96":  1,
		"_AES256GCM128": 2,
		"_AES128GCM64":  3,
		"_AES128GCM96":  4,
		"_AES128GCM128": 5,
		"_AES256CCM64":  6,
		"_AES256CCM96":  7,
		"_AES256CCM128": 8,
		"_AES128CCM64":  9,
		"_AES128CCM96":  10,
		"_AES128CCM128": 11,
	}
)

Enum value maps for EncType.

View Source 
var (
	Action_name = map[int32]string{
		0: "NONE",
		1: "FORWARD",
		2: "RECIRCULATE",
	}
	Action_value = map[string]int32{
		"NONE":        0,
		"FORWARD":     1,
		"RECIRCULATE": 2,
	}
)

Enum value maps for Action.

View Source 
var (
	MatchError_name = map[int32]string{
		0: "MISING_FIELDS",
		1: "INVALID_TUNNEL_ID",
		2: "INVALID_CAPABILITIES",
		3: "INVALID_FIELD",
	}
	MatchError_value = map[string]int32{
		"MISING_FIELDS":        0,
		"INVALID_TUNNEL_ID":    1,
		"INVALID_CAPABILITIES": 2,
		"INVALID_FIELD":        3,
	}
)

Enum value maps for MatchError.

View Source 
var (
	TunnelError_name = map[int32]string{
		0: "NOT_SUPPORTED_TUNNEL",
	}
	TunnelError_value = map[string]int32{
		"NOT_SUPPORTED_TUNNEL": 0,
	}
)

Enum value maps for TunnelError.

View Source 
var (
	IPSecError_name = map[int32]string{
		0: "INVALID_KEY",
		1: "NON_SUPPORTED_ENCRYPTION",
		2: "NON_SUPPORTED_TUNNEL_TYPE",
		3: "IPSEC_MISSING_FIELDS",
	}
	IPSecError_value = map[string]int32{
		"INVALID_KEY":               0,
		"NON_SUPPORTED_ENCRYPTION":  1,
		"NON_SUPPORTED_TUNNEL_TYPE": 2,
		"IPSEC_MISSING_FIELDS":      3,
	}
)

Enum value maps for IPSecError.

View Source 
var (
	GeneveError_name = map[int32]string{
		0: "INVALID_OPTION",
		1: "TOO_MANY_OPTIONS",
		2: "INVALID_GENEVE_FIELD",
	}
	GeneveError_value = map[string]int32{
		"INVALID_OPTION":       0,
		"TOO_MANY_OPTIONS":     1,
		"INVALID_GENEVE_FIELD": 2,
	}
)

Enum value maps for GeneveError.

View Source 
var (
	IPSecTunnelType_name = map[int32]string{
		0: "TRANSPORT",
		1: "TUNNEL",
		2: "TRANSPORT_NAT_TRAVERSAL",
		3: "TUNNEL_NAT_TRAVERSAL",
	}
	IPSecTunnelType_value = map[string]int32{
		"TRANSPORT":               0,
		"TUNNEL":                  1,
		"TRANSPORT_NAT_TRAVERSAL": 2,
		"TUNNEL_NAT_TRAVERSAL":    3,
	}
)

Enum value maps for IPSecTunnelType.

View Source 
var File_openoffload_proto protoreflect.FileDescriptor
View Source 
var File_tunneloffload_proto protoreflect.FileDescriptor

Functions

func RegisterIpTunnelServiceServer 

func RegisterIpTunnelServiceServer(s *grpc.Server, srv IpTunnelServiceServer)

func RegisterSessionTableServer 

func RegisterSessionTableServer(s *grpc.Server, srv SessionTableServer)

Types

type Action 

type Action int32
const (
	Action_NONE Action = 0
	// In this action packet will be forwarded right away
	Action_FORWARD Action = 1
	// In this action packet will continue processing, to other tunnel
	Action_RECIRCULATE Action = 2
)

func (Action) Descriptor 

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated 

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number 

func (x Action) Number() protoreflect.EnumNumber

func (Action) String 

func (x Action) String() string

func (Action) Type 

func (Action) Type() protoreflect.EnumType

type ActionParameters 

type ActionParameters struct {
	ActionType      ActionType `protobuf:"varint,1,opt,name=action_type,json=actionType,proto3,enum=openoffload.v2.ActionType" json:"action_type,omitempty"`
	ActionNextHop   uint32     `protobuf:"varint,2,opt,name=action_next_hop,json=actionNextHop,proto3" json:"action_next_hop,omitempty"`
	ActionNextHopV6 []byte     `protobuf:"bytes,3,opt,name=action_next_hop_v6,json=actionNextHopV6,proto3" json:"action_next_hop_v6,omitempty"`
	// contains filtered or unexported fields
}

MIRROR and SNOOP require an actionNextHop DROP and FORWARD do not have an actionNextHop The IPV4 nextHop definition maps to the V4 struct returned by inet_pton which is a uint32_t. The IPV6 nextHop definition maps to the V6 struct returned by inet_ptoN which is a uint8_t s6_addr[16]

func (*ActionParameters) Descriptor deprecated 

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

Deprecated: Use ActionParameters.ProtoReflect.Descriptor instead.

func (*ActionParameters) GetActionNextHop 

func (x *ActionParameters) GetActionNextHop() uint32

func (*ActionParameters) GetActionNextHopV6 

func (x *ActionParameters) GetActionNextHopV6() []byte

func (*ActionParameters) GetActionType 

func (x *ActionParameters) GetActionType() ActionType

func (*ActionParameters) ProtoMessage 

func (*ActionParameters) ProtoMessage()

func (*ActionParameters) ProtoReflect 

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

func (*ActionParameters) Reset 

func (x *ActionParameters) Reset()

func (*ActionParameters) String 

func (x *ActionParameters) String() string

type ActionType 

type ActionType int32
const (
	ActionType__DROP    ActionType = 0
	ActionType__FORWARD ActionType = 1
	ActionType__MIRROR  ActionType = 2
	ActionType__SNOOP   ActionType = 3
)

func (ActionType) Descriptor 

func (ActionType) Descriptor() protoreflect.EnumDescriptor

func (ActionType) Enum 

func (x ActionType) Enum() *ActionType

func (ActionType) EnumDescriptor deprecated 

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

Deprecated: Use ActionType.Descriptor instead.

func (ActionType) Number 

func (x ActionType) Number() protoreflect.EnumNumber

func (ActionType) String 

func (x ActionType) String() string

func (ActionType) Type 

func (ActionType) Type() protoreflect.EnumType

type AddSessionResponse 

type AddSessionResponse struct {
	RequestStatus AddSessionStatus        `` /* 138-byte string literal not displayed */
	ErrorStatus   uint64                  `protobuf:"varint,2,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"`
	StartTime     *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	ResponseError []*SessionResponseError `protobuf:"bytes,4,rep,name=response_error,json=responseError,proto3" json:"response_error,omitempty"`
	// contains filtered or unexported fields
}

In v1apha4 the errorstatus was added to act as a bitmask of errors for each of the sesssions sent in a stream (max 64).

func (*AddSessionResponse) Descriptor deprecated 

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

Deprecated: Use AddSessionResponse.ProtoReflect.Descriptor instead.

func (*AddSessionResponse) GetErrorStatus 

func (x *AddSessionResponse) GetErrorStatus() uint64

func (*AddSessionResponse) GetRequestStatus 

func (x *AddSessionResponse) GetRequestStatus() AddSessionStatus

func (*AddSessionResponse) GetResponseError 

func (x *AddSessionResponse) GetResponseError() []*SessionResponseError

func (*AddSessionResponse) GetStartTime 

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

func (*AddSessionResponse) ProtoMessage 

func (*AddSessionResponse) ProtoMessage()

func (*AddSessionResponse) ProtoReflect 

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

func (*AddSessionResponse) Reset 

func (x *AddSessionResponse) Reset()

func (*AddSessionResponse) String 

func (x *AddSessionResponse) String() string

type AddSessionStatus 

type AddSessionStatus int32

Errors for adding a session If all sessions are successful inserted return _ACCEPTED

If check of session capacity in offload device is insufficient to add all sessions do not insert any sessions and return _REJECTED_SESSION_TABLE_FULL. It is the responsibility of the client to re-try

If the server is unavailable for some other reason then return _REJECTED_SESSION_TABLE_UNAVAILABLE. It is the responsibility of the client to re-try

All other errors will return _REJECTED with a buit mask of the failed sessions and it is the responsibility of the client to address the issues

AddSessionStatus Codes Description

_SESSION_ACCEPTED: Session is accepted by the server and the client performs normal operation _SESSION_REJECTED: Session is rejected by the server as the message 

is invalid, the client needs to correct the error.

_SESSION_TABLE_FULL: Session is rejected by the server as its session table is full, 

the client needs to backoff until more space is available

_SESSION_TABLE_UNAVAILABLE: Session is rejected by the server due to an internal error 

in the server, the client needs to back off until error is corrected.

_SESSION_ALREADY_EXISTS: Session is rejected by the the server as it already exists 

in the server session table, the client will take corrective action to ensure state is consistent.

const (
	AddSessionStatus__SESSION_ACCEPTED          AddSessionStatus = 0
	AddSessionStatus__SESSION_REJECTED          AddSessionStatus = 1
	AddSessionStatus__SESSION_TABLE_FULL        AddSessionStatus = 2
	AddSessionStatus__SESSION_TABLE_UNAVAILABLE AddSessionStatus = 3
	AddSessionStatus__SESSION_ALREADY_EXISTS    AddSessionStatus = 4
)

func (AddSessionStatus) Descriptor 

func (AddSessionStatus) Descriptor() protoreflect.EnumDescriptor

func (AddSessionStatus) Enum 

func (x AddSessionStatus) Enum() *AddSessionStatus

func (AddSessionStatus) EnumDescriptor deprecated 

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

Deprecated: Use AddSessionStatus.Descriptor instead.

func (AddSessionStatus) Number 

func (x AddSessionStatus) Number() protoreflect.EnumNumber

func (AddSessionStatus) String 

func (x AddSessionStatus) String() string

func (AddSessionStatus) Type 

func (AddSessionStatus) Type() protoreflect.EnumType

type AddTunnelStatus 

type AddTunnelStatus int32

Errors for adding a tunnel If all tunnels are successful inserted return _ACCEPTED

If check of tunnel capacity in offload device is insufficient to add all tunnels do not insert any tunnels and return _REJECTED_TUNNEL_TABLE_FULL. It is the responsibility of the client to re-try

If the server is unavailable for some other reason then return _REJECTED_TUNNEL_TABLE_UNAVAILABLE. It is the responsibility of the client to re-try

All other errors will return _REJECTED with a buit mask of the failed sessions and it is the responsibility of the client to address the issues

AddTunnelStatus Codes Description

_TUNNEL_ACCEPTED: Tunnel is accepted by the server and the client performs normal operation _TUNNEL_REJECTED: Tunnel is rejected by the server as the message 

is invalid, the client needs to correct the error.

_TUNNEL_TABLE_FULL: Tunnel is rejected by the server as its session table is full, 

the client needs to backoff until more space is available

_TUNNEL_TABLE_UNAVAILABLE: Tunnel is rejected by the server due to an internal error 

in the server, the client needs to back off until error is corrected.

_TUNNEL_ALREADY_EXISTS: Tunnel is rejected by the the server as it already exists 

in the server session table, the client will take corrective action to ensure state is consistent.

const (
	AddTunnelStatus__TUNNEL_ACCEPTED          AddTunnelStatus = 0
	AddTunnelStatus__TUNNEL_REJECTED          AddTunnelStatus = 1
	AddTunnelStatus__TUNNEL_TABLE_FULL        AddTunnelStatus = 2
	AddTunnelStatus__TUNNEL_TABLE_UNAVAILABLE AddTunnelStatus = 3
	AddTunnelStatus__TUNNEL_ALREADY_EXISTS    AddTunnelStatus = 4
)

func (AddTunnelStatus) Descriptor 

func (AddTunnelStatus) Descriptor() protoreflect.EnumDescriptor

func (AddTunnelStatus) Enum 

func (x AddTunnelStatus) Enum() *AddTunnelStatus

func (AddTunnelStatus) EnumDescriptor deprecated 

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

Deprecated: Use AddTunnelStatus.Descriptor instead.

func (AddTunnelStatus) Number 

func (x AddTunnelStatus) Number() protoreflect.EnumNumber

func (AddTunnelStatus) String 

func (x AddTunnelStatus) String() string

func (AddTunnelStatus) Type 

func (AddTunnelStatus) Type() protoreflect.EnumType

type CapabilityRequest 

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

Capabilty request is empty since no paramteres are supplied to it, all capabilities will be provided at response

func (*CapabilityRequest) Descriptor deprecated 

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

Deprecated: Use CapabilityRequest.ProtoReflect.Descriptor instead.

func (*CapabilityRequest) ProtoMessage 

func (*CapabilityRequest) ProtoMessage()

func (*CapabilityRequest) ProtoReflect 

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

func (*CapabilityRequest) Reset 

func (x *CapabilityRequest) Reset()

func (*CapabilityRequest) String 

func (x *CapabilityRequest) String() string

type CapabilityResponse 

type CapabilityResponse struct {
	MatchCapabilities  *CapabilityResponse_MatchCapabilities  `protobuf:"bytes,1,opt,name=match_capabilities,json=matchCapabilities,proto3" json:"match_capabilities,omitempty"`
	IpsecCapabilities  *CapabilityResponse_IPSecCapabilities  `protobuf:"bytes,2,opt,name=ipsec_capabilities,json=ipsecCapabilities,proto3" json:"ipsec_capabilities,omitempty"`
	GeneveCapabilities *CapabilityResponse_GeneveCapabilities `protobuf:"bytes,3,opt,name=geneve_capabilities,json=geneveCapabilities,proto3" json:"geneve_capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*CapabilityResponse) Descriptor deprecated 

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

Deprecated: Use CapabilityResponse.ProtoReflect.Descriptor instead.

func (*CapabilityResponse) GetGeneveCapabilities 

func (x *CapabilityResponse) GetGeneveCapabilities() *CapabilityResponse_GeneveCapabilities

func (*CapabilityResponse) GetIpsecCapabilities 

func (x *CapabilityResponse) GetIpsecCapabilities() *CapabilityResponse_IPSecCapabilities

func (*CapabilityResponse) GetMatchCapabilities 

func (x *CapabilityResponse) GetMatchCapabilities() *CapabilityResponse_MatchCapabilities

func (*CapabilityResponse) ProtoMessage 

func (*CapabilityResponse) ProtoMessage()

func (*CapabilityResponse) ProtoReflect 

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

func (*CapabilityResponse) Reset 

func (x *CapabilityResponse) Reset()

func (*CapabilityResponse) String 

func (x *CapabilityResponse) String() string

type CapabilityResponse_GeneveCapabilities 

type CapabilityResponse_GeneveCapabilities struct {
	NumberGeneveOptionsSupported uint32 `` // Number of options geneve is supporting in encap
	/* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CapabilityResponse_GeneveCapabilities) Descriptor deprecated 

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

Deprecated: Use CapabilityResponse_GeneveCapabilities.ProtoReflect.Descriptor instead.

func (*CapabilityResponse_GeneveCapabilities) GetNumberGeneveOptionsSupported 

func (x *CapabilityResponse_GeneveCapabilities) GetNumberGeneveOptionsSupported() uint32

func (*CapabilityResponse_GeneveCapabilities) ProtoMessage 

func (*CapabilityResponse_GeneveCapabilities) ProtoMessage()

func (*CapabilityResponse_GeneveCapabilities) ProtoReflect 

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

func (*CapabilityResponse_GeneveCapabilities) Reset 

func (x *CapabilityResponse_GeneveCapabilities) Reset()

func (*CapabilityResponse_GeneveCapabilities) String 

func (x *CapabilityResponse_GeneveCapabilities) String() string

type CapabilityResponse_IPSecCapabilities 

type CapabilityResponse_IPSecCapabilities struct {
	TunnelTypeSupported []IPSecTunnelType `` /* 166-byte string literal not displayed */
	EncryptionSupported []EncType         `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CapabilityResponse_IPSecCapabilities) Descriptor deprecated 

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

Deprecated: Use CapabilityResponse_IPSecCapabilities.ProtoReflect.Descriptor instead.

func (*CapabilityResponse_IPSecCapabilities) GetEncryptionSupported 

func (x *CapabilityResponse_IPSecCapabilities) GetEncryptionSupported() []EncType

func (*CapabilityResponse_IPSecCapabilities) GetTunnelTypeSupported 

func (x *CapabilityResponse_IPSecCapabilities) GetTunnelTypeSupported() []IPSecTunnelType

func (*CapabilityResponse_IPSecCapabilities) ProtoMessage 

func (*CapabilityResponse_IPSecCapabilities) ProtoMessage()

func (*CapabilityResponse_IPSecCapabilities) ProtoReflect 

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

func (*CapabilityResponse_IPSecCapabilities) Reset 

func (x *CapabilityResponse_IPSecCapabilities) Reset()

func (*CapabilityResponse_IPSecCapabilities) String 

func (x *CapabilityResponse_IPSecCapabilities) String() string

type CapabilityResponse_MatchCapabilities 

type CapabilityResponse_MatchCapabilities struct {
	IngressInterfaceMatching bool `` // Is interface can be matched for encapsulation / decapsulation
	/* 136-byte string literal not displayed */
	VxlanMatching  bool `protobuf:"varint,2,opt,name=vxlan_matching,json=vxlanMatching,proto3" json:"vxlan_matching,omitempty"`    // Match with VXLAN VNI
	GeneveMatching bool `protobuf:"varint,3,opt,name=geneve_matching,json=geneveMatching,proto3" json:"geneve_matching,omitempty"` // Match with geneve can happen
	TunnelMatching bool `protobuf:"varint,4,opt,name=tunnel_matching,json=tunnelMatching,proto3" json:"tunnel_matching,omitempty"` // Matching on tunnel ID
	SpiMatching    bool `protobuf:"varint,5,opt,name=spi_matching,json=spiMatching,proto3" json:"spi_matching,omitempty"`          // Can match on IPSec
	// contains filtered or unexported fields
}

func (*CapabilityResponse_MatchCapabilities) Descriptor deprecated 

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

Deprecated: Use CapabilityResponse_MatchCapabilities.ProtoReflect.Descriptor instead.

func (*CapabilityResponse_MatchCapabilities) GetGeneveMatching 

func (x *CapabilityResponse_MatchCapabilities) GetGeneveMatching() bool

func (*CapabilityResponse_MatchCapabilities) GetIngressInterfaceMatching 

func (x *CapabilityResponse_MatchCapabilities) GetIngressInterfaceMatching() bool

func (*CapabilityResponse_MatchCapabilities) GetSpiMatching 

func (x *CapabilityResponse_MatchCapabilities) GetSpiMatching() bool

func (*CapabilityResponse_MatchCapabilities) GetTunnelMatching 

func (x *CapabilityResponse_MatchCapabilities) GetTunnelMatching() bool

func (*CapabilityResponse_MatchCapabilities) GetVxlanMatching 

func (x *CapabilityResponse_MatchCapabilities) GetVxlanMatching() bool

func (*CapabilityResponse_MatchCapabilities) ProtoMessage 

func (*CapabilityResponse_MatchCapabilities) ProtoMessage()

func (*CapabilityResponse_MatchCapabilities) ProtoReflect 

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

func (*CapabilityResponse_MatchCapabilities) Reset 

func (x *CapabilityResponse_MatchCapabilities) Reset()

func (*CapabilityResponse_MatchCapabilities) String 

func (x *CapabilityResponse_MatchCapabilities) String() string

type Counters 

type Counters struct {
	InPackets       uint64 `protobuf:"varint,1,opt,name=in_packets,json=inPackets,proto3" json:"in_packets,omitempty"`
	OutPackets      uint64 `protobuf:"varint,2,opt,name=out_packets,json=outPackets,proto3" json:"out_packets,omitempty"`
	InBytes         uint64 `protobuf:"varint,3,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"`
	OutBytes        uint64 `protobuf:"varint,4,opt,name=out_bytes,json=outBytes,proto3" json:"out_bytes,omitempty"`
	InPacketsDrops  uint64 `protobuf:"varint,5,opt,name=in_packets_drops,json=inPacketsDrops,proto3" json:"in_packets_drops,omitempty"`
	OutPacketsDrops uint64 `protobuf:"varint,6,opt,name=out_packets_drops,json=outPacketsDrops,proto3" json:"out_packets_drops,omitempty"`
	InBytesDrops    uint64 `protobuf:"varint,7,opt,name=in_bytes_drops,json=inBytesDrops,proto3" json:"in_bytes_drops,omitempty"`
	OutBytesDrops   uint64 `protobuf:"varint,8,opt,name=out_bytes_drops,json=outBytesDrops,proto3" json:"out_bytes_drops,omitempty"`
	// contains filtered or unexported fields
}

func (*Counters) Descriptor deprecated 

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

Deprecated: Use Counters.ProtoReflect.Descriptor instead.

func (*Counters) GetInBytes 

func (x *Counters) GetInBytes() uint64

func (*Counters) GetInBytesDrops 

func (x *Counters) GetInBytesDrops() uint64

func (*Counters) GetInPackets 

func (x *Counters) GetInPackets() uint64

func (*Counters) GetInPacketsDrops 

func (x *Counters) GetInPacketsDrops() uint64

func (*Counters) GetOutBytes 

func (x *Counters) GetOutBytes() uint64

func (*Counters) GetOutBytesDrops 

func (x *Counters) GetOutBytesDrops() uint64

func (*Counters) GetOutPackets 

func (x *Counters) GetOutPackets() uint64

func (*Counters) GetOutPacketsDrops 

func (x *Counters) GetOutPacketsDrops() uint64

func (*Counters) ProtoMessage 

func (*Counters) ProtoMessage()

func (*Counters) ProtoReflect 

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

func (*Counters) Reset 

func (x *Counters) Reset()

func (*Counters) String 

func (x *Counters) String() string

type CreateIpTunnelResponse 

type CreateIpTunnelResponse struct {

	// Tunnel ID assigned to this tunnel
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Message appears only if there's error in the response
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateIpTunnelResponse) Descriptor deprecated 

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

Deprecated: Use CreateIpTunnelResponse.ProtoReflect.Descriptor instead.

func (*CreateIpTunnelResponse) GetError 

func (x *CreateIpTunnelResponse) GetError() *Error

func (*CreateIpTunnelResponse) GetTunnelId 

func (x *CreateIpTunnelResponse) GetTunnelId() uint64

func (*CreateIpTunnelResponse) ProtoMessage 

func (*CreateIpTunnelResponse) ProtoMessage()

func (*CreateIpTunnelResponse) ProtoReflect 

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

func (*CreateIpTunnelResponse) Reset 

func (x *CreateIpTunnelResponse) Reset()

func (*CreateIpTunnelResponse) String 

func (x *CreateIpTunnelResponse) String() string

type CreateIpTunnelResponses 

type CreateIpTunnelResponses struct {
	RequestStatus AddTunnelStatus           ``                                                                                                /* 139-byte string literal not displayed */
	ErrorStatus   uint64                    `protobuf:"varint,2,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"` // bitmask of errors for each of the sesssions sent in a stream (max 64).
	Responses     []*CreateIpTunnelResponse `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateIpTunnelResponses) Descriptor deprecated 

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

Deprecated: Use CreateIpTunnelResponses.ProtoReflect.Descriptor instead.

func (*CreateIpTunnelResponses) GetErrorStatus 

func (x *CreateIpTunnelResponses) GetErrorStatus() uint64

func (*CreateIpTunnelResponses) GetRequestStatus 

func (x *CreateIpTunnelResponses) GetRequestStatus() AddTunnelStatus

func (*CreateIpTunnelResponses) GetResponses 

func (x *CreateIpTunnelResponses) GetResponses() []*CreateIpTunnelResponse

func (*CreateIpTunnelResponses) ProtoMessage 

func (*CreateIpTunnelResponses) ProtoMessage()

func (*CreateIpTunnelResponses) ProtoReflect 

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

func (*CreateIpTunnelResponses) Reset 

func (x *CreateIpTunnelResponses) Reset()

func (*CreateIpTunnelResponses) String 

func (x *CreateIpTunnelResponses) String() string

type EncType 

type EncType int32
const (
	EncType__AES256GCM64  EncType = 0
	EncType__AES256GCM96  EncType = 1
	EncType__AES256GCM128 EncType = 2
	EncType__AES128GCM64  EncType = 3
	EncType__AES128GCM96  EncType = 4
	EncType__AES128GCM128 EncType = 5
	EncType__AES256CCM64  EncType = 6
	EncType__AES256CCM96  EncType = 7
	EncType__AES256CCM128 EncType = 8
	EncType__AES128CCM64  EncType = 9
	EncType__AES128CCM96  EncType = 10
	EncType__AES128CCM128 EncType = 11
)

func (EncType) Descriptor 

func (EncType) Descriptor() protoreflect.EnumDescriptor

func (EncType) Enum 

func (x EncType) Enum() *EncType

func (EncType) EnumDescriptor deprecated 

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

Deprecated: Use EncType.Descriptor instead.

func (EncType) Number 

func (x EncType) Number() protoreflect.EnumNumber

func (EncType) String 

func (x EncType) String() string

func (EncType) Type 

func (EncType) Type() protoreflect.EnumType

type Error 

type Error struct {

	// Error code describing the error with the request
	ErrorMessage *TunnelAdditionError `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Error string indicating the error
	ErrorString string `protobuf:"bytes,2,opt,name=error_string,json=errorString,proto3" json:"error_string,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetErrorMessage 

func (x *Error) GetErrorMessage() *TunnelAdditionError

func (*Error) GetErrorString 

func (x *Error) GetErrorString() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Geneve 

type Geneve struct {

	// Types that are assignable to EncapDecap:
	//	*Geneve_GeneveEncap
	//	*Geneve_GeneveDecap
	EncapDecap isGeneve_EncapDecap `protobuf_oneof:"encap_decap"`
	// contains filtered or unexported fields
}

func (*Geneve) Descriptor deprecated 

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

Deprecated: Use Geneve.ProtoReflect.Descriptor instead.

func (*Geneve) GetEncapDecap 

func (m *Geneve) GetEncapDecap() isGeneve_EncapDecap

func (*Geneve) GetGeneveDecap 

func (x *Geneve) GetGeneveDecap() *GeneveDecap

func (*Geneve) GetGeneveEncap 

func (x *Geneve) GetGeneveEncap() *GeneveEncap

func (*Geneve) ProtoMessage 

func (*Geneve) ProtoMessage()

func (*Geneve) ProtoReflect 

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

func (*Geneve) Reset 

func (x *Geneve) Reset()

func (*Geneve) String 

func (x *Geneve) String() string

type GeneveDecap 

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

func (*GeneveDecap) Descriptor deprecated 

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

Deprecated: Use GeneveDecap.ProtoReflect.Descriptor instead.

func (*GeneveDecap) ProtoMessage 

func (*GeneveDecap) ProtoMessage()

func (*GeneveDecap) ProtoReflect 

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

func (*GeneveDecap) Reset 

func (x *GeneveDecap) Reset()

func (*GeneveDecap) String 

func (x *GeneveDecap) String() string

type GeneveEncap 

type GeneveEncap struct {

	// IP's that will be in the outer IP of encapsulated packet
	//
	// Types that are assignable to Ip:
	//	*GeneveEncap_OuterIpv4Pair
	//	*GeneveEncap_OuterIpv6Pair
	Ip isGeneveEncap_Ip `protobuf_oneof:"ip"`
	// Source & Dest mac of inner Geneve packet
	InnerMacPair          *MacPair `protobuf:"bytes,3,opt,name=inner_mac_pair,json=innerMacPair,proto3" json:"inner_mac_pair,omitempty"`
	OptionLength          uint32   `protobuf:"varint,4,opt,name=option_length,json=optionLength,proto3" json:"option_length,omitempty"`    // 6 bits - Multiply of 4 bytes
	ControlPacket         bool     `protobuf:"varint,5,opt,name=control_packet,json=controlPacket,proto3" json:"control_packet,omitempty"` // O bit at rfc. True is '1', False is '0'. Default is False.
	CriticalOptionPresent bool     ``                                                                                                      // C bit at rfc. True is '1', False is '0'. Default is False.
	/* 127-byte string literal not displayed */
	Vni          uint32          `protobuf:"varint,7,opt,name=vni,proto3" json:"vni,omitempty"`                                       // Virtual Network Identifier - 24 bits
	ProtocolType uint32          `protobuf:"varint,8,opt,name=protocol_type,json=protocolType,proto3" json:"protocol_type,omitempty"` // Currently only "Trans Ether Bridging" is supported (0x6558)
	GeneveOption []*GeneveOption `protobuf:"bytes,9,rep,name=geneve_option,json=geneveOption,proto3" json:"geneve_option,omitempty"`
	// contains filtered or unexported fields
}

func (*GeneveEncap) Descriptor deprecated 

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

Deprecated: Use GeneveEncap.ProtoReflect.Descriptor instead.

func (*GeneveEncap) GetControlPacket 

func (x *GeneveEncap) GetControlPacket() bool

func (*GeneveEncap) GetCriticalOptionPresent 

func (x *GeneveEncap) GetCriticalOptionPresent() bool

func (*GeneveEncap) GetGeneveOption 

func (x *GeneveEncap) GetGeneveOption() []*GeneveOption

func (*GeneveEncap) GetInnerMacPair 

func (x *GeneveEncap) GetInnerMacPair() *MacPair

func (*GeneveEncap) GetIp 

func (m *GeneveEncap) GetIp() isGeneveEncap_Ip

func (*GeneveEncap) GetOptionLength 

func (x *GeneveEncap) GetOptionLength() uint32

func (*GeneveEncap) GetOuterIpv4Pair 

func (x *GeneveEncap) GetOuterIpv4Pair() *IPV4Pair

func (*GeneveEncap) GetOuterIpv6Pair 

func (x *GeneveEncap) GetOuterIpv6Pair() *IPV6Pair

func (*GeneveEncap) GetProtocolType 

func (x *GeneveEncap) GetProtocolType() uint32

func (*GeneveEncap) GetVni 

func (x *GeneveEncap) GetVni() uint32

func (*GeneveEncap) ProtoMessage 

func (*GeneveEncap) ProtoMessage()

func (*GeneveEncap) ProtoReflect 

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

func (*GeneveEncap) Reset 

func (x *GeneveEncap) Reset()

func (*GeneveEncap) String 

func (x *GeneveEncap) String() string

type GeneveEncap_OuterIpv4Pair 

type GeneveEncap_OuterIpv4Pair struct {
	OuterIpv4Pair *IPV4Pair `protobuf:"bytes,1,opt,name=outer_ipv4_pair,json=outerIpv4Pair,proto3,oneof"`
}

type GeneveEncap_OuterIpv6Pair 

type GeneveEncap_OuterIpv6Pair struct {
	OuterIpv6Pair *IPV6Pair `protobuf:"bytes,2,opt,name=outer_ipv6_pair,json=outerIpv6Pair,proto3,oneof"`
}

type GeneveError 

type GeneveError int32
const (
	GeneveError_INVALID_OPTION       GeneveError = 0 // One of the options supported isn't valid
	GeneveError_TOO_MANY_OPTIONS     GeneveError = 1 // Too many options provided with the geneve tunnel
	GeneveError_INVALID_GENEVE_FIELD GeneveError = 2 // One of the fields provided in GENVE isn't valid (e.g. too big VNI)
)

func (GeneveError) Descriptor 

func (GeneveError) Descriptor() protoreflect.EnumDescriptor

func (GeneveError) Enum 

func (x GeneveError) Enum() *GeneveError

func (GeneveError) EnumDescriptor deprecated 

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

Deprecated: Use GeneveError.Descriptor instead.

func (GeneveError) Number 

func (x GeneveError) Number() protoreflect.EnumNumber

func (GeneveError) String 

func (x GeneveError) String() string

func (GeneveError) Type 

func (GeneveError) Type() protoreflect.EnumType

type GeneveOption 

type GeneveOption struct {
	OptionClass uint32 `protobuf:"varint,1,opt,name=option_class,json=optionClass,proto3" json:"option_class,omitempty"` // 16 bits
	Type        uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`                                  // 8 bits
	Length      uint32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`                              // Only 5 bits used
	// Length is multiple of 4 bytes (see https://datatracker.ietf.org/doc/html/rfc8926#section-3.5)
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // Only 4-128 bytes are acceptable,
	// contains filtered or unexported fields
}

func (*GeneveOption) Descriptor deprecated 

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

Deprecated: Use GeneveOption.ProtoReflect.Descriptor instead.

func (*GeneveOption) GetData 

func (x *GeneveOption) GetData() []byte

func (*GeneveOption) GetLength 

func (x *GeneveOption) GetLength() uint32

func (*GeneveOption) GetOptionClass 

func (x *GeneveOption) GetOptionClass() uint32

func (*GeneveOption) GetType 

func (x *GeneveOption) GetType() uint32

func (*GeneveOption) ProtoMessage 

func (*GeneveOption) ProtoMessage()

func (*GeneveOption) ProtoReflect 

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

func (*GeneveOption) Reset 

func (x *GeneveOption) Reset()

func (*GeneveOption) String 

func (x *GeneveOption) String() string

type Geneve_GeneveDecap 

type Geneve_GeneveDecap struct {
	GeneveDecap *GeneveDecap `protobuf:"bytes,2,opt,name=geneve_decap,json=geneveDecap,proto3,oneof"`
}

type Geneve_GeneveEncap 

type Geneve_GeneveEncap struct {
	GeneveEncap *GeneveEncap `protobuf:"bytes,1,opt,name=geneve_encap,json=geneveEncap,proto3,oneof"`
}

type IPSecDec 

type IPSecDec struct {
	TunnelType IPSecTunnelType `` // Transport / Tunnel...
	/* 130-byte string literal not displayed */
	EncryptionType EncType `` // AES-256GCM
	/* 134-byte string literal not displayed */
	IpsecSas []*IPSecSAParams `protobuf:"bytes,3,rep,name=ipsec_sas,json=ipsecSas,proto3" json:"ipsec_sas,omitempty"`
	// contains filtered or unexported fields
}

func (*IPSecDec) Descriptor deprecated 

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

Deprecated: Use IPSecDec.ProtoReflect.Descriptor instead.

func (*IPSecDec) GetEncryptionType 

func (x *IPSecDec) GetEncryptionType() EncType

func (*IPSecDec) GetIpsecSas 

func (x *IPSecDec) GetIpsecSas() []*IPSecSAParams

func (*IPSecDec) GetTunnelType 

func (x *IPSecDec) GetTunnelType() IPSecTunnelType

func (*IPSecDec) ProtoMessage 

func (*IPSecDec) ProtoMessage()

func (*IPSecDec) ProtoReflect 

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

func (*IPSecDec) Reset 

func (x *IPSecDec) Reset()

func (*IPSecDec) String 

func (x *IPSecDec) String() string

type IPSecEnc 

type IPSecEnc struct {
	TunnelType     IPSecTunnelType `` /* 130-byte string literal not displayed */
	EncryptionType EncType         `` /* 134-byte string literal not displayed */
	IpsecSa        *IPSecSAParams  `protobuf:"bytes,3,opt,name=ipsec_sa,json=ipsecSa,proto3" json:"ipsec_sa,omitempty"`
	// In case the ipsec tunnel is with tunnel mode,
	// one of the messages below should present
	//
	// Types that are assignable to TunnelIps:
	//	*IPSecEnc_Ipv4Tunnel
	//	*IPSecEnc_Ipv6Tunnel
	TunnelIps isIPSecEnc_TunnelIps `protobuf_oneof:"tunnelIps"`
	// contains filtered or unexported fields
}

func (*IPSecEnc) Descriptor deprecated 

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

Deprecated: Use IPSecEnc.ProtoReflect.Descriptor instead.

func (*IPSecEnc) GetEncryptionType 

func (x *IPSecEnc) GetEncryptionType() EncType

func (*IPSecEnc) GetIpsecSa 

func (x *IPSecEnc) GetIpsecSa() *IPSecSAParams

func (*IPSecEnc) GetIpv4Tunnel 

func (x *IPSecEnc) GetIpv4Tunnel() *IPV4Pair

func (*IPSecEnc) GetIpv6Tunnel 

func (x *IPSecEnc) GetIpv6Tunnel() *IPV6Pair

func (*IPSecEnc) GetTunnelIps 

func (m *IPSecEnc) GetTunnelIps() isIPSecEnc_TunnelIps

func (*IPSecEnc) GetTunnelType 

func (x *IPSecEnc) GetTunnelType() IPSecTunnelType

func (*IPSecEnc) ProtoMessage 

func (*IPSecEnc) ProtoMessage()

func (*IPSecEnc) ProtoReflect 

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

func (*IPSecEnc) Reset 

func (x *IPSecEnc) Reset()

func (*IPSecEnc) String 

func (x *IPSecEnc) String() string

type IPSecEnc_Ipv4Tunnel 

type IPSecEnc_Ipv4Tunnel struct {
	Ipv4Tunnel *IPV4Pair `protobuf:"bytes,4,opt,name=ipv4_tunnel,json=ipv4Tunnel,proto3,oneof"`
}

type IPSecEnc_Ipv6Tunnel 

type IPSecEnc_Ipv6Tunnel struct {
	Ipv6Tunnel *IPV6Pair `protobuf:"bytes,5,opt,name=ipv6_tunnel,json=ipv6Tunnel,proto3,oneof"`
}

type IPSecError 

type IPSecError int32
const (
	IPSecError_INVALID_KEY               IPSecError = 0 // Key got into IPSec is not matching the requested size
	IPSecError_NON_SUPPORTED_ENCRYPTION  IPSecError = 1 // Encrypted type requested from IPSec is not supported
	IPSecError_NON_SUPPORTED_TUNNEL_TYPE IPSecError = 2 // Tunnel type requested by IPSec is not valid (TUNNEL mode requested but not valid)
	IPSecError_IPSEC_MISSING_FIELDS      IPSecError = 3 // Some missing fields in IPSec, e.g. TUNNEL MODE without tunnel IP's provided
)

func (IPSecError) Descriptor 

func (IPSecError) Descriptor() protoreflect.EnumDescriptor

func (IPSecError) Enum 

func (x IPSecError) Enum() *IPSecError

func (IPSecError) EnumDescriptor deprecated 

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

Deprecated: Use IPSecError.Descriptor instead.

func (IPSecError) Number 

func (x IPSecError) Number() protoreflect.EnumNumber

func (IPSecError) String 

func (x IPSecError) String() string

func (IPSecError) Type 

func (IPSecError) Type() protoreflect.EnumType

type IPSecSAParams 

type IPSecSAParams struct {
	Spi           uint32    `protobuf:"varint,1,opt,name=spi,proto3" json:"spi,omitempty"`
	EncryptionKey []byte    `protobuf:"bytes,2,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
	Operation     Operation `protobuf:"varint,3,opt,name=operation,proto3,enum=tunneloffload.v2.Operation" json:"operation,omitempty"` // Indicates if removing / updating / creating SA
	// contains filtered or unexported fields
}

func (*IPSecSAParams) Descriptor deprecated 

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

Deprecated: Use IPSecSAParams.ProtoReflect.Descriptor instead.

func (*IPSecSAParams) GetEncryptionKey 

func (x *IPSecSAParams) GetEncryptionKey() []byte

func (*IPSecSAParams) GetOperation 

func (x *IPSecSAParams) GetOperation() Operation

func (*IPSecSAParams) GetSpi 

func (x *IPSecSAParams) GetSpi() uint32

func (*IPSecSAParams) ProtoMessage 

func (*IPSecSAParams) ProtoMessage()

func (*IPSecSAParams) ProtoReflect 

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

func (*IPSecSAParams) Reset 

func (x *IPSecSAParams) Reset()

func (*IPSecSAParams) String 

func (x *IPSecSAParams) String() string

type IPSecTunnel 

type IPSecTunnel struct {

	// Types that are assignable to Ipsec:
	//	*IPSecTunnel_IpsecEnc
	//	*IPSecTunnel_IpsecDec
	Ipsec isIPSecTunnel_Ipsec `protobuf_oneof:"ipsec"`
	// contains filtered or unexported fields
}

func (*IPSecTunnel) Descriptor deprecated 

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

Deprecated: Use IPSecTunnel.ProtoReflect.Descriptor instead.

func (*IPSecTunnel) GetIpsec 

func (m *IPSecTunnel) GetIpsec() isIPSecTunnel_Ipsec

func (*IPSecTunnel) GetIpsecDec 

func (x *IPSecTunnel) GetIpsecDec() *IPSecDec

func (*IPSecTunnel) GetIpsecEnc 

func (x *IPSecTunnel) GetIpsecEnc() *IPSecEnc

func (*IPSecTunnel) ProtoMessage 

func (*IPSecTunnel) ProtoMessage()

func (*IPSecTunnel) ProtoReflect 

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

func (*IPSecTunnel) Reset 

func (x *IPSecTunnel) Reset()

func (*IPSecTunnel) String 

func (x *IPSecTunnel) String() string

type IPSecTunnelType 

type IPSecTunnelType int32
const (
	IPSecTunnelType_TRANSPORT IPSecTunnelType = 0
	IPSecTunnelType_TUNNEL    IPSecTunnelType = 1
	// Nat Traversal is a mechanism to overcome Nat happens between the
	// two IPSec endpoints, by adding a UDP Header after IPSec
	// This mode can happen both in TRANSPORT & TUNNEL Mode
	// Fore more information please refer to the following RFC's:
	// https://datatracker.ietf.org/doc/html/rfc3947
	// https://datatracker.ietf.org/doc/html/rfc3715
	IPSecTunnelType_TRANSPORT_NAT_TRAVERSAL IPSecTunnelType = 2
	IPSecTunnelType_TUNNEL_NAT_TRAVERSAL    IPSecTunnelType = 3
)

func (IPSecTunnelType) Descriptor 

func (IPSecTunnelType) Descriptor() protoreflect.EnumDescriptor

func (IPSecTunnelType) Enum 

func (x IPSecTunnelType) Enum() *IPSecTunnelType

func (IPSecTunnelType) EnumDescriptor deprecated 

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

Deprecated: Use IPSecTunnelType.Descriptor instead.

func (IPSecTunnelType) Number 

func (x IPSecTunnelType) Number() protoreflect.EnumNumber

func (IPSecTunnelType) String 

func (x IPSecTunnelType) String() string

func (IPSecTunnelType) Type 

func (IPSecTunnelType) Type() protoreflect.EnumType

type IPSecTunnel_IpsecDec 

type IPSecTunnel_IpsecDec struct {
	IpsecDec *IPSecDec `protobuf:"bytes,2,opt,name=ipsec_dec,json=ipsecDec,proto3,oneof"`
}

type IPSecTunnel_IpsecEnc 

type IPSecTunnel_IpsecEnc struct {
	IpsecEnc *IPSecEnc `protobuf:"bytes,1,opt,name=ipsec_enc,json=ipsecEnc,proto3,oneof"`
}

type IPV4Match 

type IPV4Match struct {
	SourceIp            uint32 `protobuf:"fixed32,1,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	SourceIpPrefix      uint32 `protobuf:"varint,2,opt,name=source_ip_prefix,json=sourceIpPrefix,proto3" json:"source_ip_prefix,omitempty"`
	DestinationIp       uint32 `protobuf:"fixed32,3,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	DestinationIpPrefix uint32 `protobuf:"varint,4,opt,name=destination_ip_prefix,json=destinationIpPrefix,proto3" json:"destination_ip_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*IPV4Match) Descriptor deprecated 

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

Deprecated: Use IPV4Match.ProtoReflect.Descriptor instead.

func (*IPV4Match) GetDestinationIp 

func (x *IPV4Match) GetDestinationIp() uint32

func (*IPV4Match) GetDestinationIpPrefix 

func (x *IPV4Match) GetDestinationIpPrefix() uint32

func (*IPV4Match) GetSourceIp 

func (x *IPV4Match) GetSourceIp() uint32

func (*IPV4Match) GetSourceIpPrefix 

func (x *IPV4Match) GetSourceIpPrefix() uint32

func (*IPV4Match) ProtoMessage 

func (*IPV4Match) ProtoMessage()

func (*IPV4Match) ProtoReflect 

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

func (*IPV4Match) Reset 

func (x *IPV4Match) Reset()

func (*IPV4Match) String 

func (x *IPV4Match) String() string

type IPV4Pair 

type IPV4Pair struct {
	SourceIp      uint32 `protobuf:"fixed32,1,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	DestinationIp uint32 `protobuf:"fixed32,2,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*IPV4Pair) Descriptor deprecated 

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

Deprecated: Use IPV4Pair.ProtoReflect.Descriptor instead.

func (*IPV4Pair) GetDestinationIp 

func (x *IPV4Pair) GetDestinationIp() uint32

func (*IPV4Pair) GetSourceIp 

func (x *IPV4Pair) GetSourceIp() uint32

func (*IPV4Pair) ProtoMessage 

func (*IPV4Pair) ProtoMessage()

func (*IPV4Pair) ProtoReflect 

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

func (*IPV4Pair) Reset 

func (x *IPV4Pair) Reset()

func (*IPV4Pair) String 

func (x *IPV4Pair) String() string

type IPV6Match 

type IPV6Match struct {
	SourceIp            []byte `protobuf:"bytes,1,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	SourceIpPrefix      uint32 `protobuf:"varint,2,opt,name=source_ip_prefix,json=sourceIpPrefix,proto3" json:"source_ip_prefix,omitempty"`
	DestinationIp       []byte `protobuf:"bytes,3,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	DestinationIpPrefix uint32 `protobuf:"varint,4,opt,name=destination_ip_prefix,json=destinationIpPrefix,proto3" json:"destination_ip_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*IPV6Match) Descriptor deprecated 

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

Deprecated: Use IPV6Match.ProtoReflect.Descriptor instead.

func (*IPV6Match) GetDestinationIp 

func (x *IPV6Match) GetDestinationIp() []byte

func (*IPV6Match) GetDestinationIpPrefix 

func (x *IPV6Match) GetDestinationIpPrefix() uint32

func (*IPV6Match) GetSourceIp 

func (x *IPV6Match) GetSourceIp() []byte

func (*IPV6Match) GetSourceIpPrefix 

func (x *IPV6Match) GetSourceIpPrefix() uint32

func (*IPV6Match) ProtoMessage 

func (*IPV6Match) ProtoMessage()

func (*IPV6Match) ProtoReflect 

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

func (*IPV6Match) Reset 

func (x *IPV6Match) Reset()

func (*IPV6Match) String 

func (x *IPV6Match) String() string

type IPV6Pair 

type IPV6Pair struct {
	SourceIp      []byte `protobuf:"bytes,1,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	DestinationIp []byte `protobuf:"bytes,2,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*IPV6Pair) Descriptor deprecated 

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

Deprecated: Use IPV6Pair.ProtoReflect.Descriptor instead.

func (*IPV6Pair) GetDestinationIp 

func (x *IPV6Pair) GetDestinationIp() []byte

func (*IPV6Pair) GetSourceIp 

func (x *IPV6Pair) GetSourceIp() []byte

func (*IPV6Pair) ProtoMessage 

func (*IPV6Pair) ProtoMessage()

func (*IPV6Pair) ProtoReflect 

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

func (*IPV6Pair) Reset 

func (x *IPV6Pair) Reset()

func (*IPV6Pair) String 

func (x *IPV6Pair) String() string

type IpTunnelRequest 

type IpTunnelRequest struct {
	TunnelId      uint64         `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	Operation     Operation      `protobuf:"varint,2,opt,name=operation,proto3,enum=tunneloffload.v2.Operation" json:"operation,omitempty"`
	MatchCriteria *MatchCriteria `protobuf:"bytes,3,opt,name=match_criteria,json=matchCriteria,proto3" json:"match_criteria,omitempty"`                      // When hitting this match,
	NextAction    Action         `protobuf:"varint,4,opt,name=next_action,json=nextAction,proto3,enum=tunneloffload.v2.Action" json:"next_action,omitempty"` // What we'll do after matching the packet, should we
	// Types that are assignable to Tunnel:
	//	*IpTunnelRequest_IpsecTunnel
	//	*IpTunnelRequest_Geneve
	//	*IpTunnelRequest_Nat
	Tunnel isIpTunnelRequest_Tunnel `protobuf_oneof:"tunnel"`
	// contains filtered or unexported fields
}

func (*IpTunnelRequest) Descriptor deprecated 

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

Deprecated: Use IpTunnelRequest.ProtoReflect.Descriptor instead.

func (*IpTunnelRequest) GetGeneve 

func (x *IpTunnelRequest) GetGeneve() *Geneve

func (*IpTunnelRequest) GetIpsecTunnel 

func (x *IpTunnelRequest) GetIpsecTunnel() *IPSecTunnel

func (*IpTunnelRequest) GetMatchCriteria 

func (x *IpTunnelRequest) GetMatchCriteria() *MatchCriteria

func (*IpTunnelRequest) GetNat 

func (x *IpTunnelRequest) GetNat() *Nat

func (*IpTunnelRequest) GetNextAction 

func (x *IpTunnelRequest) GetNextAction() Action

func (*IpTunnelRequest) GetOperation 

func (x *IpTunnelRequest) GetOperation() Operation

func (*IpTunnelRequest) GetTunnel 

func (m *IpTunnelRequest) GetTunnel() isIpTunnelRequest_Tunnel

func (*IpTunnelRequest) GetTunnelId 

func (x *IpTunnelRequest) GetTunnelId() uint64

func (*IpTunnelRequest) ProtoMessage 

func (*IpTunnelRequest) ProtoMessage()

func (*IpTunnelRequest) ProtoReflect 

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

func (*IpTunnelRequest) Reset 

func (x *IpTunnelRequest) Reset()

func (*IpTunnelRequest) String 

func (x *IpTunnelRequest) String() string

type IpTunnelRequest_Geneve 

type IpTunnelRequest_Geneve struct {
	Geneve *Geneve `protobuf:"bytes,6,opt,name=geneve,proto3,oneof"`
}

type IpTunnelRequest_IpsecTunnel 

type IpTunnelRequest_IpsecTunnel struct {
	IpsecTunnel *IPSecTunnel `protobuf:"bytes,5,opt,name=ipsec_tunnel,json=ipsecTunnel,proto3,oneof"` // Tunnel that will be used for encapsulation, can be both
}

type IpTunnelRequest_Nat 

type IpTunnelRequest_Nat struct {
	Nat *Nat `protobuf:"bytes,7,opt,name=nat,proto3,oneof"`
}

type IpTunnelResponse 

type IpTunnelResponse struct {

	// Tunnel ID assigned to this tunnel
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Information regards the ipTunnel (including match, tunnel information)
	IpTunnel *IpTunnelRequest `protobuf:"bytes,2,opt,name=ip_tunnel,json=ipTunnel,proto3" json:"ip_tunnel,omitempty"`
	// Counters of the session
	TunnelCounters *Counters `protobuf:"bytes,3,opt,name=tunnel_counters,json=tunnelCounters,proto3" json:"tunnel_counters,omitempty"`
	// Message that appears only if there's a problem in the request
	Error *Error `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IpTunnelResponse) Descriptor deprecated 

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

Deprecated: Use IpTunnelResponse.ProtoReflect.Descriptor instead.

func (*IpTunnelResponse) GetError 

func (x *IpTunnelResponse) GetError() *Error

func (*IpTunnelResponse) GetIpTunnel 

func (x *IpTunnelResponse) GetIpTunnel() *IpTunnelRequest

func (*IpTunnelResponse) GetTunnelCounters 

func (x *IpTunnelResponse) GetTunnelCounters() *Counters

func (*IpTunnelResponse) GetTunnelId 

func (x *IpTunnelResponse) GetTunnelId() uint64

func (*IpTunnelResponse) ProtoMessage 

func (*IpTunnelResponse) ProtoMessage()

func (*IpTunnelResponse) ProtoReflect 

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

func (*IpTunnelResponse) Reset 

func (x *IpTunnelResponse) Reset()

func (*IpTunnelResponse) String 

func (x *IpTunnelResponse) String() string

type IpTunnelResponses 

type IpTunnelResponses struct {
	Responses []*IpTunnelResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*IpTunnelResponses) Descriptor deprecated 

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

Deprecated: Use IpTunnelResponses.ProtoReflect.Descriptor instead.

func (*IpTunnelResponses) GetResponses 

func (x *IpTunnelResponses) GetResponses() []*IpTunnelResponse

func (*IpTunnelResponses) ProtoMessage 

func (*IpTunnelResponses) ProtoMessage()

func (*IpTunnelResponses) ProtoReflect 

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

func (*IpTunnelResponses) Reset 

func (x *IpTunnelResponses) Reset()

func (*IpTunnelResponses) String 

func (x *IpTunnelResponses) String() string

type IpTunnelServiceClient 

type IpTunnelServiceClient interface {
	// Get which capabilities are available while using the
	Capabilities(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*CapabilityResponse, error)
	// Creation of IP Tunnel
	// This API should be generic and allow creations of many IP tunnels
	CreateIpTunnel(ctx context.Context, opts ...grpc.CallOption) (IpTunnelService_CreateIpTunnelClient, error)
	// Getting a tunnel by it's ID
	GetIpTunnel(ctx context.Context, in *TunnelId, opts ...grpc.CallOption) (*IpTunnelResponse, error)
	// Getting a tunnel by it's ID
	GetIpTunnelStats(ctx context.Context, in *TunnelId, opts ...grpc.CallOption) (*IpTunnelStatsResponse, error)
	// Getting all the ipTunnels currently configured
	GetAllIpTunnels(ctx context.Context, in *TunnelRequestArgs, opts ...grpc.CallOption) (IpTunnelService_GetAllIpTunnelsClient, error)
	// Get all the iptunnels stats responses
	GetAllIpTunnelsStats(ctx context.Context, in *TunnelRequestArgs, opts ...grpc.CallOption) (IpTunnelService_GetAllIpTunnelsStatsClient, error)
}

IpTunnelServiceClient is the client API for IpTunnelService service.

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

func NewIpTunnelServiceClient 

func NewIpTunnelServiceClient(cc grpc.ClientConnInterface) IpTunnelServiceClient

type IpTunnelServiceServer 

type IpTunnelServiceServer interface {
	// Get which capabilities are available while using the
	Capabilities(context.Context, *CapabilityRequest) (*CapabilityResponse, error)
	// Creation of IP Tunnel
	// This API should be generic and allow creations of many IP tunnels
	CreateIpTunnel(IpTunnelService_CreateIpTunnelServer) error
	// Getting a tunnel by it's ID
	GetIpTunnel(context.Context, *TunnelId) (*IpTunnelResponse, error)
	// Getting a tunnel by it's ID
	GetIpTunnelStats(context.Context, *TunnelId) (*IpTunnelStatsResponse, error)
	// Getting all the ipTunnels currently configured
	GetAllIpTunnels(*TunnelRequestArgs, IpTunnelService_GetAllIpTunnelsServer) error
	// Get all the iptunnels stats responses
	GetAllIpTunnelsStats(*TunnelRequestArgs, IpTunnelService_GetAllIpTunnelsStatsServer) error
}

IpTunnelServiceServer is the server API for IpTunnelService service.

type IpTunnelService_CreateIpTunnelClient 

type IpTunnelService_CreateIpTunnelClient interface {
	Send(*IpTunnelRequest) error
	CloseAndRecv() (*CreateIpTunnelResponses, error)
	grpc.ClientStream
}

type IpTunnelService_CreateIpTunnelServer 

type IpTunnelService_CreateIpTunnelServer interface {
	SendAndClose(*CreateIpTunnelResponses) error
	Recv() (*IpTunnelRequest, error)
	grpc.ServerStream
}

type IpTunnelService_GetAllIpTunnelsClient 

type IpTunnelService_GetAllIpTunnelsClient interface {
	Recv() (*IpTunnelResponses, error)
	grpc.ClientStream
}

type IpTunnelService_GetAllIpTunnelsServer 

type IpTunnelService_GetAllIpTunnelsServer interface {
	Send(*IpTunnelResponses) error
	grpc.ServerStream
}

type IpTunnelService_GetAllIpTunnelsStatsClient 

type IpTunnelService_GetAllIpTunnelsStatsClient interface {
	Recv() (*IpTunnelStatsResponses, error)
	grpc.ClientStream
}

type IpTunnelService_GetAllIpTunnelsStatsServer 

type IpTunnelService_GetAllIpTunnelsStatsServer interface {
	Send(*IpTunnelStatsResponses) error
	grpc.ServerStream
}

type IpTunnelStatsResponse 

type IpTunnelStatsResponse struct {

	// Tunnel ID assigned to this tunnel
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Counters of the session
	TunnelCounters *Counters `protobuf:"bytes,2,opt,name=tunnel_counters,json=tunnelCounters,proto3" json:"tunnel_counters,omitempty"`
	// Message that appears only if there's a problem in the request
	Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IpTunnelStatsResponse) Descriptor deprecated 

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

Deprecated: Use IpTunnelStatsResponse.ProtoReflect.Descriptor instead.

func (*IpTunnelStatsResponse) GetError 

func (x *IpTunnelStatsResponse) GetError() *Error

func (*IpTunnelStatsResponse) GetTunnelCounters 

func (x *IpTunnelStatsResponse) GetTunnelCounters() *Counters

func (*IpTunnelStatsResponse) GetTunnelId 

func (x *IpTunnelStatsResponse) GetTunnelId() uint64

func (*IpTunnelStatsResponse) ProtoMessage 

func (*IpTunnelStatsResponse) ProtoMessage()

func (*IpTunnelStatsResponse) ProtoReflect 

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

func (*IpTunnelStatsResponse) Reset 

func (x *IpTunnelStatsResponse) Reset()

func (*IpTunnelStatsResponse) String 

func (x *IpTunnelStatsResponse) String() string

type IpTunnelStatsResponses 

type IpTunnelStatsResponses struct {
	Responses []*IpTunnelStatsResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*IpTunnelStatsResponses) Descriptor deprecated 

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

Deprecated: Use IpTunnelStatsResponses.ProtoReflect.Descriptor instead.

func (*IpTunnelStatsResponses) GetResponses 

func (x *IpTunnelStatsResponses) GetResponses() []*IpTunnelStatsResponse

func (*IpTunnelStatsResponses) ProtoMessage 

func (*IpTunnelStatsResponses) ProtoMessage()

func (*IpTunnelStatsResponses) ProtoReflect 

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

func (*IpTunnelStatsResponses) Reset 

func (x *IpTunnelStatsResponses) Reset()

func (*IpTunnelStatsResponses) String 

func (x *IpTunnelStatsResponses) String() string

type IpVersion 

type IpVersion int32
const (
	IpVersion__IPV4 IpVersion = 0
	IpVersion__IPV6 IpVersion = 1
)

func (IpVersion) Descriptor 

func (IpVersion) Descriptor() protoreflect.EnumDescriptor

func (IpVersion) Enum 

func (x IpVersion) Enum() *IpVersion

func (IpVersion) EnumDescriptor deprecated 

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

Deprecated: Use IpVersion.Descriptor instead.

func (IpVersion) Number 

func (x IpVersion) Number() protoreflect.EnumNumber

func (IpVersion) String 

func (x IpVersion) String() string

func (IpVersion) Type 

func (IpVersion) Type() protoreflect.EnumType

type MacPair 

type MacPair struct {
	DestinationMac []byte `protobuf:"bytes,1,opt,name=destination_mac,json=destinationMac,proto3" json:"destination_mac,omitempty"`
	SourceMac      []byte `protobuf:"bytes,2,opt,name=source_mac,json=sourceMac,proto3" json:"source_mac,omitempty"`
	// contains filtered or unexported fields
}

func (*MacPair) Descriptor deprecated 

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

Deprecated: Use MacPair.ProtoReflect.Descriptor instead.

func (*MacPair) GetDestinationMac 

func (x *MacPair) GetDestinationMac() []byte

func (*MacPair) GetSourceMac 

func (x *MacPair) GetSourceMac() []byte

func (*MacPair) ProtoMessage 

func (*MacPair) ProtoMessage()

func (*MacPair) ProtoReflect 

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

func (*MacPair) Reset 

func (x *MacPair) Reset()

func (*MacPair) String 

func (x *MacPair) String() string

type MatchCriteria 

type MatchCriteria struct {

	// In case it's not present, untagged traffic will be matched
	IngressInterface string   `protobuf:"bytes,1,opt,name=ingress_interface,json=ingressInterface,proto3" json:"ingress_interface,omitempty"`
	MacMatch         *MacPair `protobuf:"bytes,2,opt,name=mac_match,json=macMatch,proto3" json:"mac_match,omitempty"` // MAC of the packet itself
	// Types that are assignable to IpMatch:
	//	*MatchCriteria_Ipv4Match
	//	*MatchCriteria_Ipv6Match
	IpMatch  isMatchCriteria_IpMatch `protobuf_oneof:"ip_match"`
	TunnelId uint64                  `protobuf:"varint,5,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"` // Match on specific tunnel
	// Tunnel Matching
	//
	// Types that are assignable to Match:
	//	*MatchCriteria_IpsecMatch
	//	*MatchCriteria_GeneveMatch_
	//	*MatchCriteria_VxlanMatch
	Match isMatchCriteria_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*MatchCriteria) Descriptor deprecated 

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

Deprecated: Use MatchCriteria.ProtoReflect.Descriptor instead.

func (*MatchCriteria) GetGeneveMatch 

func (x *MatchCriteria) GetGeneveMatch() *MatchCriteria_GeneveMatch

func (*MatchCriteria) GetIngressInterface 

func (x *MatchCriteria) GetIngressInterface() string

func (*MatchCriteria) GetIpMatch 

func (m *MatchCriteria) GetIpMatch() isMatchCriteria_IpMatch

func (*MatchCriteria) GetIpsecMatch 

func (x *MatchCriteria) GetIpsecMatch() *MatchCriteria_IPSecMatch

func (*MatchCriteria) GetIpv4Match 

func (x *MatchCriteria) GetIpv4Match() *IPV4Match

func (*MatchCriteria) GetIpv6Match 

func (x *MatchCriteria) GetIpv6Match() *IPV6Match

func (*MatchCriteria) GetMacMatch 

func (x *MatchCriteria) GetMacMatch() *MacPair

func (*MatchCriteria) GetMatch 

func (m *MatchCriteria) GetMatch() isMatchCriteria_Match

func (*MatchCriteria) GetTunnelId 

func (x *MatchCriteria) GetTunnelId() uint64

func (*MatchCriteria) GetVxlanMatch 

func (x *MatchCriteria) GetVxlanMatch() *MatchCriteria_VXLanMatch

func (*MatchCriteria) ProtoMessage 

func (*MatchCriteria) ProtoMessage()

func (*MatchCriteria) ProtoReflect 

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

func (*MatchCriteria) Reset 

func (x *MatchCriteria) Reset()

func (*MatchCriteria) String 

func (x *MatchCriteria) String() string

type MatchCriteria_GeneveMatch 

type MatchCriteria_GeneveMatch struct {
	Vni          uint32   `protobuf:"varint,1,opt,name=vni,proto3" json:"vni,omitempty"`
	MacMatch     *MacPair `protobuf:"bytes,2,opt,name=mac_match,json=macMatch,proto3" json:"mac_match,omitempty"`              // Inner Match of Geneve Packet
	ProtocolType uint32   `protobuf:"varint,3,opt,name=protocol_type,json=protocolType,proto3" json:"protocol_type,omitempty"` // Currently only "Trans Ether Bridging" is supported (0x6558)
	// Types that are assignable to IpMatch:
	//	*MatchCriteria_GeneveMatch_Ipv4Match
	//	*MatchCriteria_GeneveMatch_Ipv6Match
	IpMatch isMatchCriteria_GeneveMatch_IpMatch `protobuf_oneof:"ip_match"`
	// contains filtered or unexported fields
}

func (*MatchCriteria_GeneveMatch) Descriptor deprecated 

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

Deprecated: Use MatchCriteria_GeneveMatch.ProtoReflect.Descriptor instead.

func (*MatchCriteria_GeneveMatch) GetIpMatch 

func (m *MatchCriteria_GeneveMatch) GetIpMatch() isMatchCriteria_GeneveMatch_IpMatch

func (*MatchCriteria_GeneveMatch) GetIpv4Match 

func (x *MatchCriteria_GeneveMatch) GetIpv4Match() *IPV4Match

func (*MatchCriteria_GeneveMatch) GetIpv6Match 

func (x *MatchCriteria_GeneveMatch) GetIpv6Match() *IPV6Match

func (*MatchCriteria_GeneveMatch) GetMacMatch 

func (x *MatchCriteria_GeneveMatch) GetMacMatch() *MacPair

func (*MatchCriteria_GeneveMatch) GetProtocolType 

func (x *MatchCriteria_GeneveMatch) GetProtocolType() uint32

func (*MatchCriteria_GeneveMatch) GetVni 

func (x *MatchCriteria_GeneveMatch) GetVni() uint32

func (*MatchCriteria_GeneveMatch) ProtoMessage 

func (*MatchCriteria_GeneveMatch) ProtoMessage()

func (*MatchCriteria_GeneveMatch) ProtoReflect 

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

func (*MatchCriteria_GeneveMatch) Reset 

func (x *MatchCriteria_GeneveMatch) Reset()

func (*MatchCriteria_GeneveMatch) String 

func (x *MatchCriteria_GeneveMatch) String() string

type MatchCriteria_GeneveMatch_ 

type MatchCriteria_GeneveMatch_ struct {
	GeneveMatch *MatchCriteria_GeneveMatch `protobuf:"bytes,7,opt,name=geneve_match,json=geneveMatch,proto3,oneof"`
}

type MatchCriteria_GeneveMatch_Ipv4Match 

type MatchCriteria_GeneveMatch_Ipv4Match struct {
	Ipv4Match *IPV4Match `protobuf:"bytes,4,opt,name=ipv4_match,json=ipv4Match,proto3,oneof"`
}

type MatchCriteria_GeneveMatch_Ipv6Match 

type MatchCriteria_GeneveMatch_Ipv6Match struct {
	Ipv6Match *IPV6Match `protobuf:"bytes,5,opt,name=ipv6_match,json=ipv6Match,proto3,oneof"`
}

type MatchCriteria_IPSecMatch 

type MatchCriteria_IPSecMatch struct {
	Spi uint32 `protobuf:"varint,1,opt,name=spi,proto3" json:"spi,omitempty"`
	Sn  uint32 `protobuf:"varint,2,opt,name=sn,proto3" json:"sn,omitempty"`
	// contains filtered or unexported fields
}

func (*MatchCriteria_IPSecMatch) Descriptor deprecated 

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

Deprecated: Use MatchCriteria_IPSecMatch.ProtoReflect.Descriptor instead.

func (*MatchCriteria_IPSecMatch) GetSn 

func (x *MatchCriteria_IPSecMatch) GetSn() uint32

func (*MatchCriteria_IPSecMatch) GetSpi 

func (x *MatchCriteria_IPSecMatch) GetSpi() uint32

func (*MatchCriteria_IPSecMatch) ProtoMessage 

func (*MatchCriteria_IPSecMatch) ProtoMessage()

func (*MatchCriteria_IPSecMatch) ProtoReflect 

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

func (*MatchCriteria_IPSecMatch) Reset 

func (x *MatchCriteria_IPSecMatch) Reset()

func (*MatchCriteria_IPSecMatch) String 

func (x *MatchCriteria_IPSecMatch) String() string

type MatchCriteria_IpsecMatch 

type MatchCriteria_IpsecMatch struct {
	IpsecMatch *MatchCriteria_IPSecMatch `protobuf:"bytes,6,opt,name=ipsec_match,json=ipsecMatch,proto3,oneof"`
}

type MatchCriteria_Ipv4Match 

type MatchCriteria_Ipv4Match struct {
	Ipv4Match *IPV4Match `protobuf:"bytes,3,opt,name=ipv4_match,json=ipv4Match,proto3,oneof"`
}

type MatchCriteria_Ipv6Match 

type MatchCriteria_Ipv6Match struct {
	Ipv6Match *IPV6Match `protobuf:"bytes,4,opt,name=ipv6_match,json=ipv6Match,proto3,oneof"`
}

type MatchCriteria_VXLanMatch 

type MatchCriteria_VXLanMatch struct {
	Vni      uint32   `protobuf:"varint,1,opt,name=vni,proto3" json:"vni,omitempty"`
	MacMatch *MacPair `protobuf:"bytes,2,opt,name=mac_match,json=macMatch,proto3" json:"mac_match,omitempty"`
	// Types that are assignable to IpMatch:
	//	*MatchCriteria_VXLanMatch_Ipv4Match
	//	*MatchCriteria_VXLanMatch_Ipv6Match
	IpMatch isMatchCriteria_VXLanMatch_IpMatch `protobuf_oneof:"ip_match"`
	// contains filtered or unexported fields
}

func (*MatchCriteria_VXLanMatch) Descriptor deprecated 

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

Deprecated: Use MatchCriteria_VXLanMatch.ProtoReflect.Descriptor instead.

func (*MatchCriteria_VXLanMatch) GetIpMatch 

func (m *MatchCriteria_VXLanMatch) GetIpMatch() isMatchCriteria_VXLanMatch_IpMatch

func (*MatchCriteria_VXLanMatch) GetIpv4Match 

func (x *MatchCriteria_VXLanMatch) GetIpv4Match() *IPV4Match

func (*MatchCriteria_VXLanMatch) GetIpv6Match 

func (x *MatchCriteria_VXLanMatch) GetIpv6Match() *IPV6Match

func (*MatchCriteria_VXLanMatch) GetMacMatch 

func (x *MatchCriteria_VXLanMatch) GetMacMatch() *MacPair

func (*MatchCriteria_VXLanMatch) GetVni 

func (x *MatchCriteria_VXLanMatch) GetVni() uint32

func (*MatchCriteria_VXLanMatch) ProtoMessage 

func (*MatchCriteria_VXLanMatch) ProtoMessage()

func (*MatchCriteria_VXLanMatch) ProtoReflect 

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

func (*MatchCriteria_VXLanMatch) Reset 

func (x *MatchCriteria_VXLanMatch) Reset()

func (*MatchCriteria_VXLanMatch) String 

func (x *MatchCriteria_VXLanMatch) String() string

type MatchCriteria_VXLanMatch_Ipv4Match 

type MatchCriteria_VXLanMatch_Ipv4Match struct {
	Ipv4Match *IPV4Match `protobuf:"bytes,3,opt,name=ipv4_match,json=ipv4Match,proto3,oneof"`
}

type MatchCriteria_VXLanMatch_Ipv6Match 

type MatchCriteria_VXLanMatch_Ipv6Match struct {
	Ipv6Match *IPV6Match `protobuf:"bytes,4,opt,name=ipv6_match,json=ipv6Match,proto3,oneof"`
}

type MatchCriteria_VxlanMatch 

type MatchCriteria_VxlanMatch struct {
	VxlanMatch *MatchCriteria_VXLanMatch `protobuf:"bytes,8,opt,name=vxlan_match,json=vxlanMatch,proto3,oneof"`
}

type MatchError 

type MatchError int32
const (
	MatchError_MISING_FIELDS        MatchError = 0 // Some missing fields are misisng in the match statment
	MatchError_INVALID_TUNNEL_ID    MatchError = 1 // Tunnel ID match isn't valid or doesn't exist
	MatchError_INVALID_CAPABILITIES MatchError = 2 // The match isn't suitable with tunnel capabilities
	MatchError_INVALID_FIELD        MatchError = 3 // Invalid field found in the match (e.g. invalid mac)
)

func (MatchError) Descriptor 

func (MatchError) Descriptor() protoreflect.EnumDescriptor

func (MatchError) Enum 

func (x MatchError) Enum() *MatchError

func (MatchError) EnumDescriptor deprecated 

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

Deprecated: Use MatchError.Descriptor instead.

func (MatchError) Number 

func (x MatchError) Number() protoreflect.EnumNumber

func (MatchError) String 

func (x MatchError) String() string

func (MatchError) Type 

func (MatchError) Type() protoreflect.EnumType

type Nat 

type Nat struct {
	SourceIp uint32 `protobuf:"varint,1,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*Nat) Descriptor deprecated 

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

Deprecated: Use Nat.ProtoReflect.Descriptor instead.

func (*Nat) GetSourceIp 

func (x *Nat) GetSourceIp() uint32

func (*Nat) ProtoMessage 

func (*Nat) ProtoMessage()

func (*Nat) ProtoReflect 

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

func (*Nat) Reset 

func (x *Nat) Reset()

func (*Nat) String 

func (x *Nat) String() string

type Operation 

type Operation int32
const (
	Operation__NONE   Operation = 0
	Operation__CREATE Operation = 1
	Operation__UPDATE Operation = 2
	Operation__DELETE Operation = 3
)

func (Operation) Descriptor 

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum 

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated 

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

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number 

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String 

func (x Operation) String() string

func (Operation) Type 

func (Operation) Type() protoreflect.EnumType

type ProtocolId 

type ProtocolId int32
const (
	ProtocolId__HOPOPT ProtocolId = 0
	ProtocolId__TCP    ProtocolId = 6
	ProtocolId__UDP    ProtocolId = 17
)

func (ProtocolId) Descriptor 

func (ProtocolId) Descriptor() protoreflect.EnumDescriptor

func (ProtocolId) Enum 

func (x ProtocolId) Enum() *ProtocolId

func (ProtocolId) EnumDescriptor deprecated 

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

Deprecated: Use ProtocolId.Descriptor instead.

func (ProtocolId) Number 

func (x ProtocolId) Number() protoreflect.EnumNumber

func (ProtocolId) String 

func (x ProtocolId) String() string

func (ProtocolId) Type 

func (ProtocolId) Type() protoreflect.EnumType

type RequestStatus 

type RequestStatus int32

RequestStatus Codes Description

_ACCEPTED: Normal operation _REJECTED: Unknown error in the format of the REQUEST message _REJECTED_SESSION_NONEXISTENT: In getSession or deleteSession the server does not have the session 

in its session table. The client needs to reconcile the system state.

_REJECTED_SESSION_TABLE_FULL: This should never happen as getClosedSessions, getSession, deleteSession never add sessions. _REJECTED_SESSION_ALREADY_EXISTS: This should never happen as getClosedSessions, getSession, deleteSession never add sessions. _NO_CLOSED_SESSIONS: When getClosedSessions returns with no closed sessions it will return 0 sessions. There should be no 

message attached so not sure if this is valid.

_REJECTED_INTERNAL_ERROR: The server has an internal error and cannot serivce the request. 

The client must log the error and optionally retry or skip the request.

const (
	RequestStatus__ACCEPTED                        RequestStatus = 0
	RequestStatus__REJECTED                        RequestStatus = 1
	RequestStatus__REJECTED_SESSION_NONEXISTENT    RequestStatus = 2
	RequestStatus__REJECTED_SESSION_TABLE_FULL     RequestStatus = 3
	RequestStatus__REJECTED_SESSION_ALREADY_EXISTS RequestStatus = 4
	RequestStatus__NO_CLOSED_SESSIONS              RequestStatus = 5
	RequestStatus__REJECTED_INTERNAL_ERROR         RequestStatus = 6
)

func (RequestStatus) Descriptor 

func (RequestStatus) Descriptor() protoreflect.EnumDescriptor

func (RequestStatus) Enum 

func (x RequestStatus) Enum() *RequestStatus

func (RequestStatus) EnumDescriptor deprecated 

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

Deprecated: Use RequestStatus.Descriptor instead.

func (RequestStatus) Number 

func (x RequestStatus) Number() protoreflect.EnumNumber

func (RequestStatus) String 

func (x RequestStatus) String() string

func (RequestStatus) Type 

func (RequestStatus) Type() protoreflect.EnumType

type SessionCloseCode 

type SessionCloseCode int32
const (
	SessionCloseCode__NOT_CLOSED         SessionCloseCode = 0
	SessionCloseCode__FINACK             SessionCloseCode = 1
	SessionCloseCode__RST                SessionCloseCode = 2
	SessionCloseCode__TIMEOUT            SessionCloseCode = 3
	SessionCloseCode__UNKNOWN_CLOSE_CODE SessionCloseCode = 4
)

func (SessionCloseCode) Descriptor 

func (SessionCloseCode) Descriptor() protoreflect.EnumDescriptor

func (SessionCloseCode) Enum 

func (x SessionCloseCode) Enum() *SessionCloseCode

func (SessionCloseCode) EnumDescriptor deprecated 

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

Deprecated: Use SessionCloseCode.Descriptor instead.

func (SessionCloseCode) Number 

func (x SessionCloseCode) Number() protoreflect.EnumNumber

func (SessionCloseCode) String 

func (x SessionCloseCode) String() string

func (SessionCloseCode) Type 

func (SessionCloseCode) Type() protoreflect.EnumType

type SessionId 

type SessionId struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

should the Application assign the sessionID on AddSession and avoid conflicts or have the applications have a mechanism to avoid duplicate sessionIDs across applications since there will be many applications instances to 1 switch

func (*SessionId) Descriptor deprecated 

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

Deprecated: Use SessionId.ProtoReflect.Descriptor instead.

func (*SessionId) GetSessionId 

func (x *SessionId) GetSessionId() uint64

func (*SessionId) ProtoMessage 

func (*SessionId) ProtoMessage()

func (*SessionId) ProtoReflect 

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

func (*SessionId) Reset 

func (x *SessionId) Reset()

func (*SessionId) String 

func (x *SessionId) String() string

type SessionRequest 

type SessionRequest struct {
	SessionId       uint64            `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	InLif           int32             `protobuf:"varint,2,opt,name=in_lif,json=inLif,proto3" json:"in_lif,omitempty"`
	OutLif          int32             `protobuf:"varint,3,opt,name=out_lif,json=outLif,proto3" json:"out_lif,omitempty"`
	IpVersion       IpVersion         `protobuf:"varint,4,opt,name=ip_version,json=ipVersion,proto3,enum=openoffload.v2.IpVersion" json:"ip_version,omitempty"`
	SourceIp        uint32            `protobuf:"varint,5,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	SourceIpv6      []byte            `protobuf:"bytes,6,opt,name=source_ipv6,json=sourceIpv6,proto3" json:"source_ipv6,omitempty"`
	SourcePort      uint32            `protobuf:"varint,7,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationIp   uint32            `protobuf:"varint,8,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	DestinationIpv6 []byte            `protobuf:"bytes,9,opt,name=destination_ipv6,json=destinationIpv6,proto3" json:"destination_ipv6,omitempty"`
	DestinationPort uint32            `protobuf:"varint,10,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	ProtocolId      ProtocolId        `protobuf:"varint,11,opt,name=protocol_id,json=protocolId,proto3,enum=openoffload.v2.ProtocolId" json:"protocol_id,omitempty"`
	Action          *ActionParameters `protobuf:"bytes,12,opt,name=action,proto3" json:"action,omitempty"`
	CacheTimeout    uint32            `protobuf:"varint,13,opt,name=cache_timeout,json=cacheTimeout,proto3" json:"cache_timeout,omitempty"`
	// contains filtered or unexported fields
}

SessionId is generated by client and passed in via gRPC call The IPV4 definition maps to the V4 struct returned by inet_pton which is a uint32_t. The IPV6 definition maps to the V6 struct returned by inet_ptoN which is a uint8_t s6_addr[16]

func (*SessionRequest) Descriptor deprecated 

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

Deprecated: Use SessionRequest.ProtoReflect.Descriptor instead.

func (*SessionRequest) GetAction 

func (x *SessionRequest) GetAction() *ActionParameters

func (*SessionRequest) GetCacheTimeout 

func (x *SessionRequest) GetCacheTimeout() uint32

func (*SessionRequest) GetDestinationIp 

func (x *SessionRequest) GetDestinationIp() uint32

func (*SessionRequest) GetDestinationIpv6 

func (x *SessionRequest) GetDestinationIpv6() []byte

func (*SessionRequest) GetDestinationPort 

func (x *SessionRequest) GetDestinationPort() uint32

func (*SessionRequest) GetInLif 

func (x *SessionRequest) GetInLif() int32

func (*SessionRequest) GetIpVersion 

func (x *SessionRequest) GetIpVersion() IpVersion

func (*SessionRequest) GetOutLif 

func (x *SessionRequest) GetOutLif() int32

func (*SessionRequest) GetProtocolId 

func (x *SessionRequest) GetProtocolId() ProtocolId

func (*SessionRequest) GetSessionId 

func (x *SessionRequest) GetSessionId() uint64

func (*SessionRequest) GetSourceIp 

func (x *SessionRequest) GetSourceIp() uint32

func (*SessionRequest) GetSourceIpv6 

func (x *SessionRequest) GetSourceIpv6() []byte

func (*SessionRequest) GetSourcePort 

func (x *SessionRequest) GetSourcePort() uint32

func (*SessionRequest) ProtoMessage 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) ProtoReflect 

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

func (*SessionRequest) Reset 

func (x *SessionRequest) Reset()

func (*SessionRequest) String 

func (x *SessionRequest) String() string

type SessionRequestArgs 

type SessionRequestArgs struct {

	//  pageSize = 0 will turn off paging
	//  does paging make sense for a stream ?
	//  the client should read/process each event on the stream anyway.
	PageSize     uint32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Page         uint32 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	StartSession uint64 `protobuf:"varint,3,opt,name=start_session,json=startSession,proto3" json:"start_session,omitempty"` //  what other arguments make sense for retrieving or filtering streams
	// contains filtered or unexported fields
}

func (*SessionRequestArgs) Descriptor deprecated 

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

Deprecated: Use SessionRequestArgs.ProtoReflect.Descriptor instead.

func (*SessionRequestArgs) GetPage 

func (x *SessionRequestArgs) GetPage() uint32

func (*SessionRequestArgs) GetPageSize 

func (x *SessionRequestArgs) GetPageSize() uint32

func (*SessionRequestArgs) GetStartSession 

func (x *SessionRequestArgs) GetStartSession() uint64

func (*SessionRequestArgs) ProtoMessage 

func (*SessionRequestArgs) ProtoMessage()

func (*SessionRequestArgs) ProtoReflect 

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

func (*SessionRequestArgs) Reset 

func (x *SessionRequestArgs) Reset()

func (*SessionRequestArgs) String 

func (x *SessionRequestArgs) String() string

type SessionResponse 

type SessionResponse struct {
	SessionId        uint64                 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	InPackets        uint64                 `protobuf:"varint,2,opt,name=in_packets,json=inPackets,proto3" json:"in_packets,omitempty"`
	OutPackets       uint64                 `protobuf:"varint,3,opt,name=out_packets,json=outPackets,proto3" json:"out_packets,omitempty"`
	InBytes          uint64                 `protobuf:"varint,4,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"`
	OutBytes         uint64                 `protobuf:"varint,5,opt,name=out_bytes,json=outBytes,proto3" json:"out_bytes,omitempty"`
	SessionState     SessionState           `` /* 131-byte string literal not displayed */
	SessionCloseCode SessionCloseCode       `` /* 149-byte string literal not displayed */
	RequestStatus    RequestStatus          `` /* 135-byte string literal not displayed */
	StartTime        *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime          *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionResponse) Descriptor deprecated 

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

Deprecated: Use SessionResponse.ProtoReflect.Descriptor instead.

func (*SessionResponse) GetEndTime 

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

func (*SessionResponse) GetInBytes 

func (x *SessionResponse) GetInBytes() uint64

func (*SessionResponse) GetInPackets 

func (x *SessionResponse) GetInPackets() uint64

func (*SessionResponse) GetOutBytes 

func (x *SessionResponse) GetOutBytes() uint64

func (*SessionResponse) GetOutPackets 

func (x *SessionResponse) GetOutPackets() uint64

func (*SessionResponse) GetRequestStatus 

func (x *SessionResponse) GetRequestStatus() RequestStatus

func (*SessionResponse) GetSessionCloseCode 

func (x *SessionResponse) GetSessionCloseCode() SessionCloseCode

func (*SessionResponse) GetSessionId 

func (x *SessionResponse) GetSessionId() uint64

func (*SessionResponse) GetSessionState 

func (x *SessionResponse) GetSessionState() SessionState

func (*SessionResponse) GetStartTime 

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

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) ProtoReflect 

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

func (*SessionResponse) Reset 

func (x *SessionResponse) Reset()

func (*SessionResponse) String 

func (x *SessionResponse) String() string

type SessionResponseError 

type SessionResponseError struct {
	SessionId   uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ErrorStatus int32  `protobuf:"varint,2,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionResponseError) Descriptor deprecated 

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

Deprecated: Use SessionResponseError.ProtoReflect.Descriptor instead.

func (*SessionResponseError) GetErrorStatus 

func (x *SessionResponseError) GetErrorStatus() int32

func (*SessionResponseError) GetSessionId 

func (x *SessionResponseError) GetSessionId() uint64

func (*SessionResponseError) ProtoMessage 

func (*SessionResponseError) ProtoMessage()

func (*SessionResponseError) ProtoReflect 

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

func (*SessionResponseError) Reset 

func (x *SessionResponseError) Reset()

func (*SessionResponseError) String 

func (x *SessionResponseError) String() string

type SessionResponses 

type SessionResponses struct {
	SessionInfo []*SessionResponse `protobuf:"bytes,1,rep,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	NextKey     uint64             `protobuf:"varint,2,opt,name=next_key,json=nextKey,proto3" json:"next_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionResponses) Descriptor deprecated 

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

Deprecated: Use SessionResponses.ProtoReflect.Descriptor instead.

func (*SessionResponses) GetNextKey 

func (x *SessionResponses) GetNextKey() uint64

func (*SessionResponses) GetSessionInfo 

func (x *SessionResponses) GetSessionInfo() []*SessionResponse

func (*SessionResponses) ProtoMessage 

func (*SessionResponses) ProtoMessage()

func (*SessionResponses) ProtoReflect 

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

func (*SessionResponses) Reset 

func (x *SessionResponses) Reset()

func (*SessionResponses) String 

func (x *SessionResponses) String() string

type SessionState 

type SessionState int32
const (
	SessionState__ESTABLISHED   SessionState = 0
	SessionState__CLOSING_1     SessionState = 1
	SessionState__CLOSING_2     SessionState = 2
	SessionState__CLOSED        SessionState = 3
	SessionState__UNKNOWN_STATE SessionState = 4
)

func (SessionState) Descriptor 

func (SessionState) Descriptor() protoreflect.EnumDescriptor

func (SessionState) Enum 

func (x SessionState) Enum() *SessionState

func (SessionState) EnumDescriptor deprecated 

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

Deprecated: Use SessionState.Descriptor instead.

func (SessionState) Number 

func (x SessionState) Number() protoreflect.EnumNumber

func (SessionState) String 

func (x SessionState) String() string

func (SessionState) Type 

func (SessionState) Type() protoreflect.EnumType

type SessionTableClient 

type SessionTableClient interface {
	//
	// Adds a session
	// This was changed in v1alpha4 to be a streaming API, for performance
	// reasons.
	AddSession(ctx context.Context, opts ...grpc.CallOption) (SessionTable_AddSessionClient, error)
	//
	// Obtains the session
	GetSession(ctx context.Context, in *SessionId, opts ...grpc.CallOption) (*SessionResponse, error)
	//
	// Delete a session
	DeleteSession(ctx context.Context, in *SessionId, opts ...grpc.CallOption) (*SessionResponse, error)
	//
	// Stream back a specific session or all current sessions
	// To stream a single session, pass SessionId as zero
	GetAllSessions(ctx context.Context, in *SessionRequestArgs, opts ...grpc.CallOption) (*SessionResponses, error)
	//
	// statistics as a outgoing session from the WB to Applications ?
	// grpc seems to need a request input streamId is a placeholder
	GetClosedSessions(ctx context.Context, in *SessionRequestArgs, opts ...grpc.CallOption) (SessionTable_GetClosedSessionsClient, error)
}

SessionTableClient is the client API for SessionTable service.

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

func NewSessionTableClient 

func NewSessionTableClient(cc grpc.ClientConnInterface) SessionTableClient

type SessionTableServer 

type SessionTableServer interface {
	//
	// Adds a session
	// This was changed in v1alpha4 to be a streaming API, for performance
	// reasons.
	AddSession(SessionTable_AddSessionServer) error
	//
	// Obtains the session
	GetSession(context.Context, *SessionId) (*SessionResponse, error)
	//
	// Delete a session
	DeleteSession(context.Context, *SessionId) (*SessionResponse, error)
	//
	// Stream back a specific session or all current sessions
	// To stream a single session, pass SessionId as zero
	GetAllSessions(context.Context, *SessionRequestArgs) (*SessionResponses, error)
	//
	// statistics as a outgoing session from the WB to Applications ?
	// grpc seems to need a request input streamId is a placeholder
	GetClosedSessions(*SessionRequestArgs, SessionTable_GetClosedSessionsServer) error
}

SessionTableServer is the server API for SessionTable service.

type SessionTable_AddSessionClient 

type SessionTable_AddSessionClient interface {
	Send(*SessionRequest) error
	CloseAndRecv() (*AddSessionResponse, error)
	grpc.ClientStream
}

type SessionTable_AddSessionServer 

type SessionTable_AddSessionServer interface {
	SendAndClose(*AddSessionResponse) error
	Recv() (*SessionRequest, error)
	grpc.ServerStream
}

type SessionTable_GetClosedSessionsClient 

type SessionTable_GetClosedSessionsClient interface {
	Recv() (*SessionResponse, error)
	grpc.ClientStream
}

type SessionTable_GetClosedSessionsServer 

type SessionTable_GetClosedSessionsServer interface {
	Send(*SessionResponse) error
	grpc.ServerStream
}

type TunnelAdditionError 

type TunnelAdditionError struct {

	// Message will only present if there's error in tunnel
	MatchError  MatchError  `protobuf:"varint,1,opt,name=match_error,json=matchError,proto3,enum=tunneloffload.v2.MatchError" json:"match_error,omitempty"` // Error in match of tunnel
	TunnelError TunnelError ``                                                                                                                              // General problem in tunnel definition
	/* 129-byte string literal not displayed */
	IpsecError  IPSecError  `protobuf:"varint,3,opt,name=ipsec_error,json=ipsecError,proto3,enum=tunneloffload.v2.IPSecError" json:"ipsec_error,omitempty"` // IPSec Error
	GeneveError GeneveError ``                                                                                                                              // Error in geneve
	/* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TunnelAdditionError) Descriptor deprecated 

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

Deprecated: Use TunnelAdditionError.ProtoReflect.Descriptor instead.

func (*TunnelAdditionError) GetGeneveError 

func (x *TunnelAdditionError) GetGeneveError() GeneveError

func (*TunnelAdditionError) GetIpsecError 

func (x *TunnelAdditionError) GetIpsecError() IPSecError

func (*TunnelAdditionError) GetMatchError 

func (x *TunnelAdditionError) GetMatchError() MatchError

func (*TunnelAdditionError) GetTunnelError 

func (x *TunnelAdditionError) GetTunnelError() TunnelError

func (*TunnelAdditionError) ProtoMessage 

func (*TunnelAdditionError) ProtoMessage()

func (*TunnelAdditionError) ProtoReflect 

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

func (*TunnelAdditionError) Reset 

func (x *TunnelAdditionError) Reset()

func (*TunnelAdditionError) String 

func (x *TunnelAdditionError) String() string

type TunnelError 

type TunnelError int32
const (
	TunnelError_NOT_SUPPORTED_TUNNEL TunnelError = 0 // Tunnel offload requested to non supported tunnel
)

func (TunnelError) Descriptor 

func (TunnelError) Descriptor() protoreflect.EnumDescriptor

func (TunnelError) Enum 

func (x TunnelError) Enum() *TunnelError

func (TunnelError) EnumDescriptor deprecated 

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

Deprecated: Use TunnelError.Descriptor instead.

func (TunnelError) Number 

func (x TunnelError) Number() protoreflect.EnumNumber

func (TunnelError) String 

func (x TunnelError) String() string

func (TunnelError) Type 

func (TunnelError) Type() protoreflect.EnumType

type TunnelId 

type TunnelId struct {
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelId) Descriptor deprecated 

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

Deprecated: Use TunnelId.ProtoReflect.Descriptor instead.

func (*TunnelId) GetTunnelId 

func (x *TunnelId) GetTunnelId() uint64

func (*TunnelId) ProtoMessage 

func (*TunnelId) ProtoMessage()

func (*TunnelId) ProtoReflect 

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

func (*TunnelId) Reset 

func (x *TunnelId) Reset()

func (*TunnelId) String 

func (x *TunnelId) String() string

type TunnelRequestArgs 

type TunnelRequestArgs struct {
	TunnelsPerRequest uint32 `protobuf:"varint,1,opt,name=tunnels_per_request,json=tunnelsPerRequest,proto3" json:"tunnels_per_request,omitempty"` // How many tunnels will be returned per request
	// contains filtered or unexported fields
}

func (*TunnelRequestArgs) Descriptor deprecated 

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

Deprecated: Use TunnelRequestArgs.ProtoReflect.Descriptor instead.

func (*TunnelRequestArgs) GetTunnelsPerRequest 

func (x *TunnelRequestArgs) GetTunnelsPerRequest() uint32

func (*TunnelRequestArgs) ProtoMessage 

func (*TunnelRequestArgs) ProtoMessage()

func (*TunnelRequestArgs) ProtoReflect 

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

func (*TunnelRequestArgs) Reset 

func (x *TunnelRequestArgs) Reset()

func (*TunnelRequestArgs) String 

func (x *TunnelRequestArgs) String() string

type UnimplementedIpTunnelServiceServer 

type UnimplementedIpTunnelServiceServer struct {
}

UnimplementedIpTunnelServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIpTunnelServiceServer) Capabilities 

func (*UnimplementedIpTunnelServiceServer) Capabilities(context.Context, *CapabilityRequest) (*CapabilityResponse, error)

func (*UnimplementedIpTunnelServiceServer) CreateIpTunnel 

func (*UnimplementedIpTunnelServiceServer) CreateIpTunnel(IpTunnelService_CreateIpTunnelServer) error

func (*UnimplementedIpTunnelServiceServer) GetAllIpTunnels 

func (*UnimplementedIpTunnelServiceServer) GetAllIpTunnels(*TunnelRequestArgs, IpTunnelService_GetAllIpTunnelsServer) error

func (*UnimplementedIpTunnelServiceServer) GetAllIpTunnelsStats 

func (*UnimplementedIpTunnelServiceServer) GetAllIpTunnelsStats(*TunnelRequestArgs, IpTunnelService_GetAllIpTunnelsStatsServer) error

func (*UnimplementedIpTunnelServiceServer) GetIpTunnel 

func (*UnimplementedIpTunnelServiceServer) GetIpTunnel(context.Context, *TunnelId) (*IpTunnelResponse, error)

func (*UnimplementedIpTunnelServiceServer) GetIpTunnelStats 

func (*UnimplementedIpTunnelServiceServer) GetIpTunnelStats(context.Context, *TunnelId) (*IpTunnelStatsResponse, error)

type UnimplementedSessionTableServer 

type UnimplementedSessionTableServer struct {
}

UnimplementedSessionTableServer can be embedded to have forward compatible implementations.

func (*UnimplementedSessionTableServer) AddSession 

func (*UnimplementedSessionTableServer) AddSession(SessionTable_AddSessionServer) error

func (*UnimplementedSessionTableServer) DeleteSession 

func (*UnimplementedSessionTableServer) DeleteSession(context.Context, *SessionId) (*SessionResponse, error)

func (*UnimplementedSessionTableServer) GetAllSessions 

func (*UnimplementedSessionTableServer) GetAllSessions(context.Context, *SessionRequestArgs) (*SessionResponses, error)

func (*UnimplementedSessionTableServer) GetClosedSessions 

func (*UnimplementedSessionTableServer) GetClosedSessions(*SessionRequestArgs, SessionTable_GetClosedSessionsServer) error

func (*UnimplementedSessionTableServer) GetSession 

func (*UnimplementedSessionTableServer) GetSession(context.Context, *SessionId) (*SessionResponse, error)

type Uuid 

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

Uuid for Session IDs

func (*Uuid) Descriptor deprecated 

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

Deprecated: Use Uuid.ProtoReflect.Descriptor instead.

func (*Uuid) GetValue 

func (x *Uuid) GetValue() string

func (*Uuid) ProtoMessage 

func (*Uuid) ProtoMessage()

func (*Uuid) ProtoReflect 

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

func (*Uuid) Reset 

func (x *Uuid) Reset()

func (*Uuid) String 

func (x *Uuid) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.