rpc

package
Version: v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2021 License: Apache-2.0 Imports: 8 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	IPType_name = map[int32]string{
		0: "TypeVPCIP",
		1: "TypeVPCENI",
		2: "TypeENIMultiIP",
	}
	IPType_value = map[string]int32{
		"TypeVPCIP":      0,
		"TypeVPCENI":     1,
		"TypeENIMultiIP": 2,
	}
)

Enum value maps for IPType.

View Source
var (
	EventTarget_name = map[int32]string{
		0: "EventTargetNode",
		1: "EventTargetPod",
	}
	EventTarget_value = map[string]int32{
		"EventTargetNode": 0,
		"EventTargetPod":  1,
	}
)

Enum value maps for EventTarget.

View Source
var (
	EventType_name = map[int32]string{
		0: "EventTypeNormal",
		1: "EventTypeWarning",
	}
	EventType_value = map[string]int32{
		"EventTypeNormal":  0,
		"EventTypeWarning": 1,
	}
)

Enum value maps for EventType.

View Source
var (
	ResourceMappingType_name = map[int32]string{
		0: "MappingTypeNormal",
		1: "MappingTypeIdle",
		2: "MappingTypeError",
	}
	ResourceMappingType_value = map[string]int32{
		"MappingTypeNormal": 0,
		"MappingTypeIdle":   1,
		"MappingTypeError":  2,
	}
)

Enum value maps for ResourceMappingType.

View Source
var File_tracing_proto protoreflect.FileDescriptor
View Source
var TerwayBackend_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.TerwayBackend",
	HandlerType: (*TerwayBackendServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AllocIP",
			Handler:    _TerwayBackend_AllocIP_Handler,
		},
		{
			MethodName: "ReleaseIP",
			Handler:    _TerwayBackend_ReleaseIP_Handler,
		},
		{
			MethodName: "GetIPInfo",
			Handler:    _TerwayBackend_GetIPInfo_Handler,
		},
		{
			MethodName: "RecordEvent",
			Handler:    _TerwayBackend_RecordEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc.proto",
}

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

View Source
var TerwayTracing_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.TerwayTracing",
	HandlerType: (*TerwayTracingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetResourceTypes",
			Handler:    _TerwayTracing_GetResourceTypes_Handler,
		},
		{
			MethodName: "GetResources",
			Handler:    _TerwayTracing_GetResources_Handler,
		},
		{
			MethodName: "GetResourceConfig",
			Handler:    _TerwayTracing_GetResourceConfig_Handler,
		},
		{
			MethodName: "GetResourceTrace",
			Handler:    _TerwayTracing_GetResourceTrace_Handler,
		},
		{
			MethodName: "GetResourceMapping",
			Handler:    _TerwayTracing_GetResourceMapping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ResourceExecute",
			Handler:       _TerwayTracing_ResourceExecute_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "tracing.proto",
}

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

Functions

func RegisterTerwayBackendServer

func RegisterTerwayBackendServer(s grpc.ServiceRegistrar, srv TerwayBackendServer)

func RegisterTerwayTracingServer added in v1.1.0

func RegisterTerwayTracingServer(s grpc.ServiceRegistrar, srv TerwayTracingServer)

Types

type AllocIPReply

type AllocIPReply struct {
	Success   bool       `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	IPType    IPType     `protobuf:"varint,2,opt,name=IPType,proto3,enum=rpc.IPType" json:"IPType,omitempty"`
	BasicInfo *BasicInfo `protobuf:"bytes,3,opt,name=BasicInfo,proto3" json:"BasicInfo,omitempty"`
	ENIInfo   *ENIInfo   `protobuf:"bytes,4,opt,name=ENIInfo,proto3" json:"ENIInfo,omitempty"`
	Pod       *Pod       `protobuf:"bytes,5,opt,name=Pod,proto3" json:"Pod,omitempty"`
	IPv4      bool       `protobuf:"varint,6,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6      bool       `protobuf:"varint,7,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocIPReply) Descriptor deprecated

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

Deprecated: Use AllocIPReply.ProtoReflect.Descriptor instead.

func (*AllocIPReply) GetBasicInfo added in v1.1.0

func (x *AllocIPReply) GetBasicInfo() *BasicInfo

func (*AllocIPReply) GetENIInfo added in v1.1.0

func (x *AllocIPReply) GetENIInfo() *ENIInfo

func (*AllocIPReply) GetIPType

func (x *AllocIPReply) GetIPType() IPType

func (*AllocIPReply) GetIPv4 added in v1.1.0

func (x *AllocIPReply) GetIPv4() bool

func (*AllocIPReply) GetIPv6 added in v1.1.0

func (x *AllocIPReply) GetIPv6() bool

func (*AllocIPReply) GetPod added in v1.1.0

func (x *AllocIPReply) GetPod() *Pod

func (*AllocIPReply) GetSuccess

func (x *AllocIPReply) GetSuccess() bool

func (*AllocIPReply) ProtoMessage

func (*AllocIPReply) ProtoMessage()

func (*AllocIPReply) ProtoReflect added in v1.1.0

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

func (*AllocIPReply) Reset

func (x *AllocIPReply) Reset()

func (*AllocIPReply) String

func (x *AllocIPReply) String() string

type AllocIPRequest

type AllocIPRequest struct {
	K8SPodName             string `protobuf:"bytes,1,opt,name=K8sPodName,proto3" json:"K8sPodName,omitempty"`
	K8SPodNamespace        string `protobuf:"bytes,2,opt,name=K8sPodNamespace,proto3" json:"K8sPodNamespace,omitempty"`
	K8SPodInfraContainerId string `protobuf:"bytes,3,opt,name=K8sPodInfraContainerId,proto3" json:"K8sPodInfraContainerId,omitempty"`
	Netns                  string `protobuf:"bytes,4,opt,name=Netns,proto3" json:"Netns,omitempty"`
	IfName                 string `protobuf:"bytes,5,opt,name=IfName,proto3" json:"IfName,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocIPRequest) Descriptor deprecated

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

Deprecated: Use AllocIPRequest.ProtoReflect.Descriptor instead.

func (*AllocIPRequest) GetIfName

func (x *AllocIPRequest) GetIfName() string

func (*AllocIPRequest) GetK8SPodInfraContainerId

func (x *AllocIPRequest) GetK8SPodInfraContainerId() string

func (*AllocIPRequest) GetK8SPodName

func (x *AllocIPRequest) GetK8SPodName() string

func (*AllocIPRequest) GetK8SPodNamespace

func (x *AllocIPRequest) GetK8SPodNamespace() string

func (*AllocIPRequest) GetNetns

func (x *AllocIPRequest) GetNetns() string

func (*AllocIPRequest) ProtoMessage

func (*AllocIPRequest) ProtoMessage()

func (*AllocIPRequest) ProtoReflect added in v1.1.0

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

func (*AllocIPRequest) Reset

func (x *AllocIPRequest) Reset()

func (*AllocIPRequest) String

func (x *AllocIPRequest) String() string

type BasicInfo added in v1.1.0

type BasicInfo struct {
	PodIP       *IPSet `protobuf:"bytes,1,opt,name=PodIP,proto3" json:"PodIP,omitempty"`
	PodCIDR     *IPSet `protobuf:"bytes,2,opt,name=PodCIDR,proto3" json:"PodCIDR,omitempty"`     // subnet for pod, value form vSwitch CIDR or podCIDR
	GatewayIP   *IPSet `protobuf:"bytes,3,opt,name=GatewayIP,proto3" json:"GatewayIP,omitempty"` // gw for the subnet
	ServiceCIDR *IPSet `protobuf:"bytes,4,opt,name=ServiceCIDR,proto3" json:"ServiceCIDR,omitempty"`
	// contains filtered or unexported fields
}

func (*BasicInfo) Descriptor deprecated added in v1.1.0

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

Deprecated: Use BasicInfo.ProtoReflect.Descriptor instead.

func (*BasicInfo) GetGatewayIP added in v1.1.0

func (x *BasicInfo) GetGatewayIP() *IPSet

func (*BasicInfo) GetPodCIDR added in v1.1.0

func (x *BasicInfo) GetPodCIDR() *IPSet

func (*BasicInfo) GetPodIP added in v1.1.0

func (x *BasicInfo) GetPodIP() *IPSet

func (*BasicInfo) GetServiceCIDR added in v1.1.0

func (x *BasicInfo) GetServiceCIDR() *IPSet

func (*BasicInfo) ProtoMessage added in v1.1.0

func (*BasicInfo) ProtoMessage()

func (*BasicInfo) ProtoReflect added in v1.1.0

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

func (*BasicInfo) Reset added in v1.1.0

func (x *BasicInfo) Reset()

func (*BasicInfo) String added in v1.1.0

func (x *BasicInfo) String() string

type ENIInfo added in v1.1.0

type ENIInfo struct {
	MAC   string `protobuf:"bytes,1,opt,name=MAC,proto3" json:"MAC,omitempty"`
	Trunk bool   `protobuf:"varint,2,opt,name=Trunk,proto3" json:"Trunk,omitempty"` // eni is trunk
	// contains filtered or unexported fields
}

func (*ENIInfo) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ENIInfo.ProtoReflect.Descriptor instead.

func (*ENIInfo) GetMAC added in v1.1.0

func (x *ENIInfo) GetMAC() string

func (*ENIInfo) GetTrunk added in v1.1.0

func (x *ENIInfo) GetTrunk() bool

func (*ENIInfo) ProtoMessage added in v1.1.0

func (*ENIInfo) ProtoMessage()

func (*ENIInfo) ProtoReflect added in v1.1.0

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

func (*ENIInfo) Reset added in v1.1.0

func (x *ENIInfo) Reset()

func (*ENIInfo) String added in v1.1.0

func (x *ENIInfo) String() string

type EventReply added in v1.1.0

type EventReply struct {
	Succeed bool   `protobuf:"varint,1,opt,name=Succeed,proto3" json:"Succeed,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*EventReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use EventReply.ProtoReflect.Descriptor instead.

func (*EventReply) GetError added in v1.1.0

func (x *EventReply) GetError() string

func (*EventReply) GetSucceed added in v1.1.0

func (x *EventReply) GetSucceed() bool

func (*EventReply) ProtoMessage added in v1.1.0

func (*EventReply) ProtoMessage()

func (*EventReply) ProtoReflect added in v1.1.0

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

func (*EventReply) Reset added in v1.1.0

func (x *EventReply) Reset()

func (*EventReply) String added in v1.1.0

func (x *EventReply) String() string

type EventRequest added in v1.1.0

type EventRequest struct {
	EventTarget     EventTarget `protobuf:"varint,1,opt,name=EventTarget,proto3,enum=rpc.EventTarget" json:"EventTarget,omitempty"`
	K8SPodName      string      `protobuf:"bytes,2,opt,name=K8sPodName,proto3" json:"K8sPodName,omitempty"`
	K8SPodNamespace string      `protobuf:"bytes,3,opt,name=K8sPodNamespace,proto3" json:"K8sPodNamespace,omitempty"`
	EventType       EventType   `protobuf:"varint,4,opt,name=EventType,proto3,enum=rpc.EventType" json:"EventType,omitempty"`
	Reason          string      `protobuf:"bytes,5,opt,name=Reason,proto3" json:"Reason,omitempty"`
	Message         string      `protobuf:"bytes,6,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRequest) Descriptor deprecated added in v1.1.0

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

Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.

func (*EventRequest) GetEventTarget added in v1.1.0

func (x *EventRequest) GetEventTarget() EventTarget

func (*EventRequest) GetEventType added in v1.1.0

func (x *EventRequest) GetEventType() EventType

func (*EventRequest) GetK8SPodName added in v1.1.0

func (x *EventRequest) GetK8SPodName() string

func (*EventRequest) GetK8SPodNamespace added in v1.1.0

func (x *EventRequest) GetK8SPodNamespace() string

func (*EventRequest) GetMessage added in v1.1.0

func (x *EventRequest) GetMessage() string

func (*EventRequest) GetReason added in v1.1.0

func (x *EventRequest) GetReason() string

func (*EventRequest) ProtoMessage added in v1.1.0

func (*EventRequest) ProtoMessage()

func (*EventRequest) ProtoReflect added in v1.1.0

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

func (*EventRequest) Reset added in v1.1.0

func (x *EventRequest) Reset()

func (*EventRequest) String added in v1.1.0

func (x *EventRequest) String() string

type EventTarget added in v1.1.0

type EventTarget int32
const (
	EventTarget_EventTargetNode EventTarget = 0
	EventTarget_EventTargetPod  EventTarget = 1
)

func (EventTarget) Descriptor added in v1.1.0

func (EventTarget) Enum added in v1.1.0

func (x EventTarget) Enum() *EventTarget

func (EventTarget) EnumDescriptor deprecated added in v1.1.0

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

Deprecated: Use EventTarget.Descriptor instead.

func (EventTarget) Number added in v1.1.0

func (x EventTarget) Number() protoreflect.EnumNumber

func (EventTarget) String added in v1.1.0

func (x EventTarget) String() string

func (EventTarget) Type added in v1.1.0

type EventType added in v1.1.0

type EventType int32
const (
	EventType_EventTypeNormal  EventType = 0
	EventType_EventTypeWarning EventType = 1
)

func (EventType) Descriptor added in v1.1.0

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v1.1.0

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v1.1.0

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v1.1.0

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v1.1.0

func (x EventType) String() string

func (EventType) Type added in v1.1.0

type GetInfoReply

type GetInfoReply struct {
	IPType    IPType     `protobuf:"varint,1,opt,name=IPType,proto3,enum=rpc.IPType" json:"IPType,omitempty"`
	BasicInfo *BasicInfo `protobuf:"bytes,2,opt,name=BasicInfo,proto3" json:"BasicInfo,omitempty"`
	ENIInfo   *ENIInfo   `protobuf:"bytes,3,opt,name=ENIInfo,proto3" json:"ENIInfo,omitempty"`
	Pod       *Pod       `protobuf:"bytes,4,opt,name=Pod,proto3" json:"Pod,omitempty"`
	IPv4      bool       `protobuf:"varint,5,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6      bool       `protobuf:"varint,6,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoReply) Descriptor deprecated

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

Deprecated: Use GetInfoReply.ProtoReflect.Descriptor instead.

func (*GetInfoReply) GetBasicInfo added in v1.1.0

func (x *GetInfoReply) GetBasicInfo() *BasicInfo

func (*GetInfoReply) GetENIInfo added in v1.1.0

func (x *GetInfoReply) GetENIInfo() *ENIInfo

func (*GetInfoReply) GetIPType

func (x *GetInfoReply) GetIPType() IPType

func (*GetInfoReply) GetIPv4 added in v1.1.0

func (x *GetInfoReply) GetIPv4() bool

func (*GetInfoReply) GetIPv6 added in v1.1.0

func (x *GetInfoReply) GetIPv6() bool

func (*GetInfoReply) GetPod added in v1.1.0

func (x *GetInfoReply) GetPod() *Pod

func (*GetInfoReply) ProtoMessage

func (*GetInfoReply) ProtoMessage()

func (*GetInfoReply) ProtoReflect added in v1.1.0

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

func (*GetInfoReply) Reset

func (x *GetInfoReply) Reset()

func (*GetInfoReply) String

func (x *GetInfoReply) String() string

type GetInfoRequest

type GetInfoRequest struct {
	K8SPodName             string `protobuf:"bytes,1,opt,name=K8sPodName,proto3" json:"K8sPodName,omitempty"`
	K8SPodNamespace        string `protobuf:"bytes,2,opt,name=K8sPodNamespace,proto3" json:"K8sPodNamespace,omitempty"`
	K8SPodInfraContainerId string `protobuf:"bytes,3,opt,name=K8sPodInfraContainerId,proto3" json:"K8sPodInfraContainerId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoRequest) Descriptor deprecated

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

Deprecated: Use GetInfoRequest.ProtoReflect.Descriptor instead.

func (*GetInfoRequest) GetK8SPodInfraContainerId

func (x *GetInfoRequest) GetK8SPodInfraContainerId() string

func (*GetInfoRequest) GetK8SPodName

func (x *GetInfoRequest) GetK8SPodName() string

func (*GetInfoRequest) GetK8SPodNamespace

func (x *GetInfoRequest) GetK8SPodNamespace() string

func (*GetInfoRequest) ProtoMessage

func (*GetInfoRequest) ProtoMessage()

func (*GetInfoRequest) ProtoReflect added in v1.1.0

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

func (*GetInfoRequest) Reset

func (x *GetInfoRequest) Reset()

func (*GetInfoRequest) String

func (x *GetInfoRequest) String() string

type IPSet added in v1.1.0

type IPSet struct {
	IPv4 string `protobuf:"bytes,1,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6 string `protobuf:"bytes,2,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	// contains filtered or unexported fields
}

IPSet declare a string set contain v4 v6 info

func (*IPSet) Descriptor deprecated added in v1.1.0

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

Deprecated: Use IPSet.ProtoReflect.Descriptor instead.

func (*IPSet) GetIPv4 added in v1.1.0

func (x *IPSet) GetIPv4() string

func (*IPSet) GetIPv6 added in v1.1.0

func (x *IPSet) GetIPv6() string

func (*IPSet) ProtoMessage added in v1.1.0

func (*IPSet) ProtoMessage()

func (*IPSet) ProtoReflect added in v1.1.0

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

func (*IPSet) Reset added in v1.1.0

func (x *IPSet) Reset()

func (*IPSet) String added in v1.1.0

func (x *IPSet) String() string

type IPType

type IPType int32
const (
	IPType_TypeVPCIP      IPType = 0
	IPType_TypeVPCENI     IPType = 1
	IPType_TypeENIMultiIP IPType = 2
)

func (IPType) Descriptor added in v1.1.0

func (IPType) Descriptor() protoreflect.EnumDescriptor

func (IPType) Enum added in v1.1.0

func (x IPType) Enum() *IPType

func (IPType) EnumDescriptor deprecated

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

Deprecated: Use IPType.Descriptor instead.

func (IPType) Number added in v1.1.0

func (x IPType) Number() protoreflect.EnumNumber

func (IPType) String

func (x IPType) String() string

func (IPType) Type added in v1.1.0

func (IPType) Type() protoreflect.EnumType

type MapKeyValueEntry added in v1.1.0

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

func (*MapKeyValueEntry) Descriptor deprecated added in v1.1.0

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

Deprecated: Use MapKeyValueEntry.ProtoReflect.Descriptor instead.

func (*MapKeyValueEntry) GetKey added in v1.1.0

func (x *MapKeyValueEntry) GetKey() string

func (*MapKeyValueEntry) GetValue added in v1.1.0

func (x *MapKeyValueEntry) GetValue() string

func (*MapKeyValueEntry) ProtoMessage added in v1.1.0

func (*MapKeyValueEntry) ProtoMessage()

func (*MapKeyValueEntry) ProtoReflect added in v1.1.0

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

func (*MapKeyValueEntry) Reset added in v1.1.0

func (x *MapKeyValueEntry) Reset()

func (*MapKeyValueEntry) String added in v1.1.0

func (x *MapKeyValueEntry) String() string

type Placeholder added in v1.1.0

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

func (*Placeholder) Descriptor deprecated added in v1.1.0

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

Deprecated: Use Placeholder.ProtoReflect.Descriptor instead.

func (*Placeholder) ProtoMessage added in v1.1.0

func (*Placeholder) ProtoMessage()

func (*Placeholder) ProtoReflect added in v1.1.0

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

func (*Placeholder) Reset added in v1.1.0

func (x *Placeholder) Reset()

func (*Placeholder) String added in v1.1.0

func (x *Placeholder) String() string

type Pod

type Pod struct {
	Ingress uint64 `protobuf:"varint,1,opt,name=Ingress,proto3" json:"Ingress,omitempty"`
	Egress  uint64 `protobuf:"varint,2,opt,name=Egress,proto3" json:"Egress,omitempty"`
	// contains filtered or unexported fields
}

VETH Basic

func (*Pod) Descriptor deprecated

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

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetEgress

func (x *Pod) GetEgress() uint64

func (*Pod) GetIngress

func (x *Pod) GetIngress() uint64

func (*Pod) ProtoMessage

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect added in v1.1.0

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

func (*Pod) Reset

func (x *Pod) Reset()

func (*Pod) String

func (x *Pod) String() string

type PodResourceMapping added in v1.1.0

type PodResourceMapping struct {
	Type                ResourceMappingType `protobuf:"varint,1,opt,name=type,proto3,enum=rpc.ResourceMappingType" json:"type,omitempty"`
	PodName             string              `protobuf:"bytes,2,opt,name=PodName,proto3" json:"PodName,omitempty"`
	ResourceName        string              `protobuf:"bytes,3,opt,name=ResourceName,proto3" json:"ResourceName,omitempty"`
	FactoryResourceName string              `protobuf:"bytes,4,opt,name=FactoryResourceName,proto3" json:"FactoryResourceName,omitempty"`
	// contains filtered or unexported fields
}

func (*PodResourceMapping) Descriptor deprecated added in v1.1.0

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

Deprecated: Use PodResourceMapping.ProtoReflect.Descriptor instead.

func (*PodResourceMapping) GetFactoryResourceName added in v1.1.0

func (x *PodResourceMapping) GetFactoryResourceName() string

func (*PodResourceMapping) GetPodName added in v1.1.0

func (x *PodResourceMapping) GetPodName() string

func (*PodResourceMapping) GetResourceName added in v1.1.0

func (x *PodResourceMapping) GetResourceName() string

func (*PodResourceMapping) GetType added in v1.1.0

func (*PodResourceMapping) ProtoMessage added in v1.1.0

func (*PodResourceMapping) ProtoMessage()

func (*PodResourceMapping) ProtoReflect added in v1.1.0

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

func (*PodResourceMapping) Reset added in v1.1.0

func (x *PodResourceMapping) Reset()

func (*PodResourceMapping) String added in v1.1.0

func (x *PodResourceMapping) String() string

type PodResourceMappingReply added in v1.1.0

type PodResourceMappingReply struct {
	Info []*PodResourceMapping `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*PodResourceMappingReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use PodResourceMappingReply.ProtoReflect.Descriptor instead.

func (*PodResourceMappingReply) GetInfo added in v1.1.0

func (*PodResourceMappingReply) ProtoMessage added in v1.1.0

func (*PodResourceMappingReply) ProtoMessage()

func (*PodResourceMappingReply) ProtoReflect added in v1.1.0

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

func (*PodResourceMappingReply) Reset added in v1.1.0

func (x *PodResourceMappingReply) Reset()

func (*PodResourceMappingReply) String added in v1.1.0

func (x *PodResourceMappingReply) String() string

type ReleaseIPReply

type ReleaseIPReply struct {
	Success      bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	IPv4Addr     *IPSet `protobuf:"bytes,2,opt,name=IPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	DeviceNumber int32  `protobuf:"varint,3,opt,name=DeviceNumber,proto3" json:"DeviceNumber,omitempty"`
	IPv4         bool   `protobuf:"varint,4,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6         bool   `protobuf:"varint,5,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseIPReply) Descriptor deprecated

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

Deprecated: Use ReleaseIPReply.ProtoReflect.Descriptor instead.

func (*ReleaseIPReply) GetDeviceNumber

func (x *ReleaseIPReply) GetDeviceNumber() int32

func (*ReleaseIPReply) GetIPv4 added in v1.1.0

func (x *ReleaseIPReply) GetIPv4() bool

func (*ReleaseIPReply) GetIPv4Addr

func (x *ReleaseIPReply) GetIPv4Addr() *IPSet

func (*ReleaseIPReply) GetIPv6 added in v1.1.0

func (x *ReleaseIPReply) GetIPv6() bool

func (*ReleaseIPReply) GetSuccess

func (x *ReleaseIPReply) GetSuccess() bool

func (*ReleaseIPReply) ProtoMessage

func (*ReleaseIPReply) ProtoMessage()

func (*ReleaseIPReply) ProtoReflect added in v1.1.0

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

func (*ReleaseIPReply) Reset

func (x *ReleaseIPReply) Reset()

func (*ReleaseIPReply) String

func (x *ReleaseIPReply) String() string

type ReleaseIPRequest

type ReleaseIPRequest struct {
	K8SPodName             string `protobuf:"bytes,1,opt,name=K8sPodName,proto3" json:"K8sPodName,omitempty"`
	K8SPodNamespace        string `protobuf:"bytes,2,opt,name=K8sPodNamespace,proto3" json:"K8sPodNamespace,omitempty"`
	K8SPodInfraContainerId string `protobuf:"bytes,3,opt,name=K8sPodInfraContainerId,proto3" json:"K8sPodInfraContainerId,omitempty"`
	IPType                 IPType `protobuf:"varint,4,opt,name=IPType,proto3,enum=rpc.IPType" json:"IPType,omitempty"`
	IPv4Addr               *IPSet `protobuf:"bytes,5,opt,name=IPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	MacAddr                string `protobuf:"bytes,6,opt,name=MacAddr,proto3" json:"MacAddr,omitempty"`
	Reason                 string `protobuf:"bytes,7,opt,name=Reason,proto3" json:"Reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseIPRequest) Descriptor deprecated

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

Deprecated: Use ReleaseIPRequest.ProtoReflect.Descriptor instead.

func (*ReleaseIPRequest) GetIPType

func (x *ReleaseIPRequest) GetIPType() IPType

func (*ReleaseIPRequest) GetIPv4Addr

func (x *ReleaseIPRequest) GetIPv4Addr() *IPSet

func (*ReleaseIPRequest) GetK8SPodInfraContainerId

func (x *ReleaseIPRequest) GetK8SPodInfraContainerId() string

func (*ReleaseIPRequest) GetK8SPodName

func (x *ReleaseIPRequest) GetK8SPodName() string

func (*ReleaseIPRequest) GetK8SPodNamespace

func (x *ReleaseIPRequest) GetK8SPodNamespace() string

func (*ReleaseIPRequest) GetMacAddr

func (x *ReleaseIPRequest) GetMacAddr() string

func (*ReleaseIPRequest) GetReason

func (x *ReleaseIPRequest) GetReason() string

func (*ReleaseIPRequest) ProtoMessage

func (*ReleaseIPRequest) ProtoMessage()

func (*ReleaseIPRequest) ProtoReflect added in v1.1.0

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

func (*ReleaseIPRequest) Reset

func (x *ReleaseIPRequest) Reset()

func (*ReleaseIPRequest) String

func (x *ReleaseIPRequest) String() string

type ResourceConfigReply added in v1.1.0

type ResourceConfigReply struct {
	Config []*MapKeyValueEntry `protobuf:"bytes,1,rep,name=Config,proto3" json:"Config,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceConfigReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceConfigReply.ProtoReflect.Descriptor instead.

func (*ResourceConfigReply) GetConfig added in v1.1.0

func (x *ResourceConfigReply) GetConfig() []*MapKeyValueEntry

func (*ResourceConfigReply) ProtoMessage added in v1.1.0

func (*ResourceConfigReply) ProtoMessage()

func (*ResourceConfigReply) ProtoReflect added in v1.1.0

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

func (*ResourceConfigReply) Reset added in v1.1.0

func (x *ResourceConfigReply) Reset()

func (*ResourceConfigReply) String added in v1.1.0

func (x *ResourceConfigReply) String() string

type ResourceExecuteReply added in v1.1.0

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

func (*ResourceExecuteReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceExecuteReply.ProtoReflect.Descriptor instead.

func (*ResourceExecuteReply) GetMessage added in v1.1.0

func (x *ResourceExecuteReply) GetMessage() string

func (*ResourceExecuteReply) ProtoMessage added in v1.1.0

func (*ResourceExecuteReply) ProtoMessage()

func (*ResourceExecuteReply) ProtoReflect added in v1.1.0

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

func (*ResourceExecuteReply) Reset added in v1.1.0

func (x *ResourceExecuteReply) Reset()

func (*ResourceExecuteReply) String added in v1.1.0

func (x *ResourceExecuteReply) String() string

type ResourceExecuteRequest added in v1.1.0

type ResourceExecuteRequest struct {
	Type    string   `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Command string   `protobuf:"bytes,3,opt,name=Command,proto3" json:"Command,omitempty"`
	Args    []string `protobuf:"bytes,4,rep,name=Args,proto3" json:"Args,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceExecuteRequest) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceExecuteRequest.ProtoReflect.Descriptor instead.

func (*ResourceExecuteRequest) GetArgs added in v1.1.0

func (x *ResourceExecuteRequest) GetArgs() []string

func (*ResourceExecuteRequest) GetCommand added in v1.1.0

func (x *ResourceExecuteRequest) GetCommand() string

func (*ResourceExecuteRequest) GetName added in v1.1.0

func (x *ResourceExecuteRequest) GetName() string

func (*ResourceExecuteRequest) GetType added in v1.1.0

func (x *ResourceExecuteRequest) GetType() string

func (*ResourceExecuteRequest) ProtoMessage added in v1.1.0

func (*ResourceExecuteRequest) ProtoMessage()

func (*ResourceExecuteRequest) ProtoReflect added in v1.1.0

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

func (*ResourceExecuteRequest) Reset added in v1.1.0

func (x *ResourceExecuteRequest) Reset()

func (*ResourceExecuteRequest) String added in v1.1.0

func (x *ResourceExecuteRequest) String() string

type ResourceMappingType added in v1.1.0

type ResourceMappingType int32
const (
	ResourceMappingType_MappingTypeNormal ResourceMappingType = 0 // Pod -> Resource -> Factory
	ResourceMappingType_MappingTypeIdle   ResourceMappingType = 1 // x -> Resource -> Factory
	ResourceMappingType_MappingTypeError  ResourceMappingType = 2 // x -> x -> Factory
)

func (ResourceMappingType) Descriptor added in v1.1.0

func (ResourceMappingType) Enum added in v1.1.0

func (ResourceMappingType) EnumDescriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceMappingType.Descriptor instead.

func (ResourceMappingType) Number added in v1.1.0

func (ResourceMappingType) String added in v1.1.0

func (x ResourceMappingType) String() string

func (ResourceMappingType) Type added in v1.1.0

type ResourceTraceReply added in v1.1.0

type ResourceTraceReply struct {
	Trace []*MapKeyValueEntry `protobuf:"bytes,1,rep,name=Trace,proto3" json:"Trace,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceTraceReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceTraceReply.ProtoReflect.Descriptor instead.

func (*ResourceTraceReply) GetTrace added in v1.1.0

func (x *ResourceTraceReply) GetTrace() []*MapKeyValueEntry

func (*ResourceTraceReply) ProtoMessage added in v1.1.0

func (*ResourceTraceReply) ProtoMessage()

func (*ResourceTraceReply) ProtoReflect added in v1.1.0

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

func (*ResourceTraceReply) Reset added in v1.1.0

func (x *ResourceTraceReply) Reset()

func (*ResourceTraceReply) String added in v1.1.0

func (x *ResourceTraceReply) String() string

type ResourceTypeNameRequest added in v1.1.0

type ResourceTypeNameRequest struct {
	Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceTypeNameRequest) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceTypeNameRequest.ProtoReflect.Descriptor instead.

func (*ResourceTypeNameRequest) GetName added in v1.1.0

func (x *ResourceTypeNameRequest) GetName() string

func (*ResourceTypeNameRequest) GetType added in v1.1.0

func (x *ResourceTypeNameRequest) GetType() string

func (*ResourceTypeNameRequest) ProtoMessage added in v1.1.0

func (*ResourceTypeNameRequest) ProtoMessage()

func (*ResourceTypeNameRequest) ProtoReflect added in v1.1.0

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

func (*ResourceTypeNameRequest) Reset added in v1.1.0

func (x *ResourceTypeNameRequest) Reset()

func (*ResourceTypeNameRequest) String added in v1.1.0

func (x *ResourceTypeNameRequest) String() string

type ResourceTypeRequest added in v1.1.0

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

func (*ResourceTypeRequest) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourceTypeRequest.ProtoReflect.Descriptor instead.

func (*ResourceTypeRequest) GetName added in v1.1.0

func (x *ResourceTypeRequest) GetName() string

func (*ResourceTypeRequest) ProtoMessage added in v1.1.0

func (*ResourceTypeRequest) ProtoMessage()

func (*ResourceTypeRequest) ProtoReflect added in v1.1.0

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

func (*ResourceTypeRequest) Reset added in v1.1.0

func (x *ResourceTypeRequest) Reset()

func (*ResourceTypeRequest) String added in v1.1.0

func (x *ResourceTypeRequest) String() string

type ResourcesNamesReply added in v1.1.0

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

func (*ResourcesNamesReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourcesNamesReply.ProtoReflect.Descriptor instead.

func (*ResourcesNamesReply) GetResourceNames added in v1.1.0

func (x *ResourcesNamesReply) GetResourceNames() []string

func (*ResourcesNamesReply) ProtoMessage added in v1.1.0

func (*ResourcesNamesReply) ProtoMessage()

func (*ResourcesNamesReply) ProtoReflect added in v1.1.0

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

func (*ResourcesNamesReply) Reset added in v1.1.0

func (x *ResourcesNamesReply) Reset()

func (*ResourcesNamesReply) String added in v1.1.0

func (x *ResourcesNamesReply) String() string

type ResourcesTypesReply added in v1.1.0

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

func (*ResourcesTypesReply) Descriptor deprecated added in v1.1.0

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

Deprecated: Use ResourcesTypesReply.ProtoReflect.Descriptor instead.

func (*ResourcesTypesReply) GetTypeNames added in v1.1.0

func (x *ResourcesTypesReply) GetTypeNames() []string

func (*ResourcesTypesReply) ProtoMessage added in v1.1.0

func (*ResourcesTypesReply) ProtoMessage()

func (*ResourcesTypesReply) ProtoReflect added in v1.1.0

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

func (*ResourcesTypesReply) Reset added in v1.1.0

func (x *ResourcesTypesReply) Reset()

func (*ResourcesTypesReply) String added in v1.1.0

func (x *ResourcesTypesReply) String() string

type TerwayBackendClient

type TerwayBackendClient interface {
	AllocIP(ctx context.Context, in *AllocIPRequest, opts ...grpc.CallOption) (*AllocIPReply, error)
	ReleaseIP(ctx context.Context, in *ReleaseIPRequest, opts ...grpc.CallOption) (*ReleaseIPReply, error)
	GetIPInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoReply, error)
	RecordEvent(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*EventReply, error)
}

TerwayBackendClient is the client API for TerwayBackend service.

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

type TerwayBackendServer

type TerwayBackendServer interface {
	AllocIP(context.Context, *AllocIPRequest) (*AllocIPReply, error)
	ReleaseIP(context.Context, *ReleaseIPRequest) (*ReleaseIPReply, error)
	GetIPInfo(context.Context, *GetInfoRequest) (*GetInfoReply, error)
	RecordEvent(context.Context, *EventRequest) (*EventReply, error)
	// contains filtered or unexported methods
}

TerwayBackendServer is the server API for TerwayBackend service. All implementations must embed UnimplementedTerwayBackendServer for forward compatibility

type TerwayTracingClient added in v1.1.0

type TerwayTracingClient interface {
	GetResourceTypes(ctx context.Context, in *Placeholder, opts ...grpc.CallOption) (*ResourcesTypesReply, error)
	GetResources(ctx context.Context, in *ResourceTypeRequest, opts ...grpc.CallOption) (*ResourcesNamesReply, error)
	GetResourceConfig(ctx context.Context, in *ResourceTypeNameRequest, opts ...grpc.CallOption) (*ResourceConfigReply, error)
	GetResourceTrace(ctx context.Context, in *ResourceTypeNameRequest, opts ...grpc.CallOption) (*ResourceTraceReply, error)
	ResourceExecute(ctx context.Context, in *ResourceExecuteRequest, opts ...grpc.CallOption) (TerwayTracing_ResourceExecuteClient, error)
	GetResourceMapping(ctx context.Context, in *Placeholder, opts ...grpc.CallOption) (*PodResourceMappingReply, error)
}

TerwayTracingClient is the client API for TerwayTracing service.

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

func NewTerwayTracingClient added in v1.1.0

func NewTerwayTracingClient(cc grpc.ClientConnInterface) TerwayTracingClient

type TerwayTracingServer added in v1.1.0

type TerwayTracingServer interface {
	GetResourceTypes(context.Context, *Placeholder) (*ResourcesTypesReply, error)
	GetResources(context.Context, *ResourceTypeRequest) (*ResourcesNamesReply, error)
	GetResourceConfig(context.Context, *ResourceTypeNameRequest) (*ResourceConfigReply, error)
	GetResourceTrace(context.Context, *ResourceTypeNameRequest) (*ResourceTraceReply, error)
	ResourceExecute(*ResourceExecuteRequest, TerwayTracing_ResourceExecuteServer) error
	GetResourceMapping(context.Context, *Placeholder) (*PodResourceMappingReply, error)
	// contains filtered or unexported methods
}

TerwayTracingServer is the server API for TerwayTracing service. All implementations must embed UnimplementedTerwayTracingServer for forward compatibility

type TerwayTracing_ResourceExecuteClient added in v1.1.0

type TerwayTracing_ResourceExecuteClient interface {
	Recv() (*ResourceExecuteReply, error)
	grpc.ClientStream
}

type TerwayTracing_ResourceExecuteServer added in v1.1.0

type TerwayTracing_ResourceExecuteServer interface {
	Send(*ResourceExecuteReply) error
	grpc.ServerStream
}

type UnimplementedTerwayBackendServer added in v1.1.0

type UnimplementedTerwayBackendServer struct {
}

UnimplementedTerwayBackendServer must be embedded to have forward compatible implementations.

func (UnimplementedTerwayBackendServer) AllocIP added in v1.1.0

func (UnimplementedTerwayBackendServer) GetIPInfo added in v1.1.0

func (UnimplementedTerwayBackendServer) RecordEvent added in v1.1.0

func (UnimplementedTerwayBackendServer) ReleaseIP added in v1.1.0

type UnimplementedTerwayTracingServer added in v1.1.0

type UnimplementedTerwayTracingServer struct {
}

UnimplementedTerwayTracingServer must be embedded to have forward compatible implementations.

func (UnimplementedTerwayTracingServer) GetResourceConfig added in v1.1.0

func (UnimplementedTerwayTracingServer) GetResourceMapping added in v1.1.0

func (UnimplementedTerwayTracingServer) GetResourceTrace added in v1.1.0

func (UnimplementedTerwayTracingServer) GetResourceTypes added in v1.1.0

func (UnimplementedTerwayTracingServer) GetResources added in v1.1.0

func (UnimplementedTerwayTracingServer) ResourceExecute added in v1.1.0

type UnsafeTerwayBackendServer added in v1.1.0

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

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

type UnsafeTerwayTracingServer added in v1.1.0

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

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

Jump to

Keyboard shortcuts

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