rpc

package
v1.3.0-policy Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2022 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 (
	Error_name = map[int32]string{
		0: "ErrNoErr",
		1: "ErrCRDNotFound",
	}
	Error_value = map[string]int32{
		"ErrNoErr":       0,
		"ErrCRDNotFound": 1,
	}
)

Enum value maps for Error.

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_rpc_proto protoreflect.FileDescriptor
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"`
	IPv4           bool       `protobuf:"varint,3,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6           bool       `protobuf:"varint,4,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	NetConfs       []*NetConf `protobuf:"bytes,5,rep,name=NetConfs,proto3" json:"NetConfs,omitempty"`
	EnableTrunking bool       `protobuf:"varint,6,opt,name=EnableTrunking,proto3" json:"EnableTrunking,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocIPReply) Descriptor deprecated 

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

Deprecated: Use AllocIPReply.ProtoReflect.Descriptor instead.

func (*AllocIPReply) GetEnableTrunking added in v1.2.0 

func (x *AllocIPReply) GetEnableTrunking() bool

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) GetNetConfs added in v1.2.0 

func (x *AllocIPReply) GetNetConfs() []*NetConf

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
	Vid       uint32 `protobuf:"varint,3,opt,name=Vid,proto3" json:"Vid,omitempty"`     // vlan ID
	GatewayIP *IPSet `protobuf:"bytes,4,opt,name=GatewayIP,proto3" json:"GatewayIP,omitempty"`
	// 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) GetGatewayIP added in v1.2.2 

func (x *ENIInfo) GetGatewayIP() *IPSet

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) GetVid added in v1.2.0 

func (x *ENIInfo) GetVid() uint32

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 Error added in v1.2.0 

type Error int32
const (
	Error_ErrNoErr       Error = 0
	Error_ErrCRDNotFound Error = 1
)

func (Error) Descriptor added in v1.2.0 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum added in v1.2.0 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated added in v1.2.0 

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

Deprecated: Use Error.Descriptor instead.

func (Error) Number added in v1.2.0 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String added in v1.2.0 

func (x Error) String() string

func (Error) Type added in v1.2.0 

func (Error) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 

func (EventTarget) Type() protoreflect.EnumType

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 

func (EventType) Type() protoreflect.EnumType

type GetInfoReply 

type GetInfoReply struct {
	IPType         IPType     `protobuf:"varint,1,opt,name=IPType,proto3,enum=rpc.IPType" json:"IPType,omitempty"`
	Success        bool       `protobuf:"varint,2,opt,name=Success,proto3" json:"Success,omitempty"`
	IPv4           bool       `protobuf:"varint,3,opt,name=IPv4,proto3" json:"IPv4,omitempty"`
	IPv6           bool       `protobuf:"varint,4,opt,name=IPv6,proto3" json:"IPv6,omitempty"`
	NetConfs       []*NetConf `protobuf:"bytes,5,rep,name=NetConfs,proto3" json:"NetConfs,omitempty"`
	EnableTrunking bool       `protobuf:"varint,6,opt,name=EnableTrunking,proto3" json:"EnableTrunking,omitempty"`
	Error          Error      `protobuf:"varint,7,opt,name=Error,proto3,enum=rpc.Error" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoReply) Descriptor deprecated 

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

Deprecated: Use GetInfoReply.ProtoReflect.Descriptor instead.

func (*GetInfoReply) GetEnableTrunking added in v1.2.0 

func (x *GetInfoReply) GetEnableTrunking() bool

func (*GetInfoReply) GetError added in v1.2.0 

func (x *GetInfoReply) GetError() Error

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) GetNetConfs added in v1.2.0 

func (x *GetInfoReply) GetNetConfs() []*NetConf

func (*GetInfoReply) GetSuccess added in v1.2.0 

func (x *GetInfoReply) GetSuccess() bool

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 NetConf added in v1.2.0 

type NetConf struct {
	BasicInfo    *BasicInfo `protobuf:"bytes,1,opt,name=BasicInfo,proto3" json:"BasicInfo,omitempty"`
	ENIInfo      *ENIInfo   `protobuf:"bytes,2,opt,name=ENIInfo,proto3" json:"ENIInfo,omitempty"`
	Pod          *Pod       `protobuf:"bytes,3,opt,name=Pod,proto3" json:"Pod,omitempty"`
	IfName       string     `protobuf:"bytes,4,opt,name=IfName,proto3" json:"IfName,omitempty"`
	ExtraRoutes  []*Route   `protobuf:"bytes,5,rep,name=ExtraRoutes,proto3" json:"ExtraRoutes,omitempty"`
	DefaultRoute bool       `protobuf:"varint,6,opt,name=DefaultRoute,proto3" json:"DefaultRoute,omitempty"`
	// contains filtered or unexported fields
}

func (*NetConf) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use NetConf.ProtoReflect.Descriptor instead.

func (*NetConf) GetBasicInfo added in v1.2.0 

func (x *NetConf) GetBasicInfo() *BasicInfo

func (*NetConf) GetDefaultRoute added in v1.2.0 

func (x *NetConf) GetDefaultRoute() bool

func (*NetConf) GetENIInfo added in v1.2.0 

func (x *NetConf) GetENIInfo() *ENIInfo

func (*NetConf) GetExtraRoutes added in v1.2.0 

func (x *NetConf) GetExtraRoutes() []*Route

func (*NetConf) GetIfName added in v1.2.0 

func (x *NetConf) GetIfName() string

func (*NetConf) GetPod added in v1.2.0 

func (x *NetConf) GetPod() *Pod

func (*NetConf) ProtoMessage added in v1.2.0 

func (*NetConf) ProtoMessage()

func (*NetConf) ProtoReflect added in v1.2.0 

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

func (*NetConf) Reset added in v1.2.0 

func (x *NetConf) Reset()

func (*NetConf) String added in v1.2.0 

func (x *NetConf) 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 (x *PodResourceMapping) GetType() ResourceMappingType

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 (x *PodResourceMappingReply) GetInfo() []*PodResourceMapping

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) Descriptor() protoreflect.EnumDescriptor

func (ResourceMappingType) Enum added in v1.1.0 

func (x ResourceMappingType) Enum() *ResourceMappingType

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 (x ResourceMappingType) Number() protoreflect.EnumNumber

func (ResourceMappingType) String added in v1.1.0 

func (x ResourceMappingType) String() string

func (ResourceMappingType) Type added in v1.1.0 

func (ResourceMappingType) Type() protoreflect.EnumType

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 Route added in v1.2.0 

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

func (*Route) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetDst added in v1.2.0 

func (x *Route) GetDst() string

func (*Route) ProtoMessage added in v1.2.0 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect added in v1.2.0 

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

func (*Route) Reset added in v1.2.0 

func (x *Route) Reset()

func (*Route) String added in v1.2.0 

func (x *Route) 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.

func NewTerwayBackendClient 

func NewTerwayBackendClient(cc grpc.ClientConnInterface) TerwayBackendClient

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) AllocIP(context.Context, *AllocIPRequest) (*AllocIPReply, error)

func (UnimplementedTerwayBackendServer) GetIPInfo added in v1.1.0 

func (UnimplementedTerwayBackendServer) GetIPInfo(context.Context, *GetInfoRequest) (*GetInfoReply, error)

func (UnimplementedTerwayBackendServer) RecordEvent added in v1.1.0 

func (UnimplementedTerwayBackendServer) RecordEvent(context.Context, *EventRequest) (*EventReply, error)

func (UnimplementedTerwayBackendServer) ReleaseIP added in v1.1.0 

func (UnimplementedTerwayBackendServer) ReleaseIP(context.Context, *ReleaseIPRequest) (*ReleaseIPReply, error)

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) GetResourceConfig(context.Context, *ResourceTypeNameRequest) (*ResourceConfigReply, error)

func (UnimplementedTerwayTracingServer) GetResourceMapping added in v1.1.0 

func (UnimplementedTerwayTracingServer) GetResourceMapping(context.Context, *Placeholder) (*PodResourceMappingReply, error)

func (UnimplementedTerwayTracingServer) GetResourceTrace added in v1.1.0 

func (UnimplementedTerwayTracingServer) GetResourceTrace(context.Context, *ResourceTypeNameRequest) (*ResourceTraceReply, error)

func (UnimplementedTerwayTracingServer) GetResourceTypes added in v1.1.0 

func (UnimplementedTerwayTracingServer) GetResourceTypes(context.Context, *Placeholder) (*ResourcesTypesReply, error)

func (UnimplementedTerwayTracingServer) GetResources added in v1.1.0 

func (UnimplementedTerwayTracingServer) GetResources(context.Context, *ResourceTypeRequest) (*ResourcesNamesReply, error)

func (UnimplementedTerwayTracingServer) ResourceExecute added in v1.1.0 

func (UnimplementedTerwayTracingServer) ResourceExecute(*ResourceExecuteRequest, TerwayTracing_ResourceExecuteServer) error

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.

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.