zdsapi

package
v0.0.0-...-4b288b9 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Version_name = map[int32]string{
		0: "NOT_USED",
		1: "V1",
	}
	Version_value = map[string]int32{
		"NOT_USED": 0,
		"V1":       1,
	}
)

Enum value maps for Version.

View Source 
var File_zdsapi_zds_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Ack 

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

Ztunnel ack message. If error is not empty, this is an error message.

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetError 

func (x *Ack) GetError() string

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type AddWorkload 

type AddWorkload struct {
	Uid          string        `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	WorkloadInfo *WorkloadInfo `protobuf:"bytes,2,opt,name=workload_info,json=workloadInfo,proto3" json:"workload_info,omitempty"`
	// contains filtered or unexported fields
}

Add a workload to the ztunnel. this will be accompanied by ancillary data contianing the workload's netns file descriptor.

func (*AddWorkload) Descriptor deprecated 

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

Deprecated: Use AddWorkload.ProtoReflect.Descriptor instead.

func (*AddWorkload) GetUid 

func (x *AddWorkload) GetUid() string

func (*AddWorkload) GetWorkloadInfo 

func (x *AddWorkload) GetWorkloadInfo() *WorkloadInfo

func (*AddWorkload) ProtoMessage 

func (*AddWorkload) ProtoMessage()

func (*AddWorkload) ProtoReflect 

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

func (*AddWorkload) Reset 

func (x *AddWorkload) Reset()

func (*AddWorkload) String 

func (x *AddWorkload) String() string

type DelWorkload 

type DelWorkload struct {
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

Delete a workload from the ztunnel. Ztunnel should shutdown the workload's proxy.

func (*DelWorkload) Descriptor deprecated 

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

Deprecated: Use DelWorkload.ProtoReflect.Descriptor instead.

func (*DelWorkload) GetUid 

func (x *DelWorkload) GetUid() string

func (*DelWorkload) ProtoMessage 

func (*DelWorkload) ProtoMessage()

func (*DelWorkload) ProtoReflect 

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

func (*DelWorkload) Reset 

func (x *DelWorkload) Reset()

func (*DelWorkload) String 

func (x *DelWorkload) String() string

type KeepWorkload 

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

Keep workload that we can't find in the fd cache. This can only be sent before SnapshotSent is sent to signal ztunnel to not delete the workload if it has it.

func (*KeepWorkload) Descriptor deprecated 

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

Deprecated: Use KeepWorkload.ProtoReflect.Descriptor instead.

func (*KeepWorkload) GetUid 

func (x *KeepWorkload) GetUid() string

func (*KeepWorkload) ProtoMessage 

func (*KeepWorkload) ProtoMessage()

func (*KeepWorkload) ProtoReflect 

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

func (*KeepWorkload) Reset 

func (x *KeepWorkload) Reset()

func (*KeepWorkload) String 

func (x *KeepWorkload) String() string

type SnapshotSent 

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

Let ztunnel know that a full snapshot was sent. Ztunnel should reconcile its internal state and remove internal entries that were not sent.

func (*SnapshotSent) Descriptor deprecated 

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

Deprecated: Use SnapshotSent.ProtoReflect.Descriptor instead.

func (*SnapshotSent) ProtoMessage 

func (*SnapshotSent) ProtoMessage()

func (*SnapshotSent) ProtoReflect 

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

func (*SnapshotSent) Reset 

func (x *SnapshotSent) Reset()

func (*SnapshotSent) String 

func (x *SnapshotSent) String() string

type Version 

type Version int32
const (
	Version_NOT_USED Version = 0
	Version_V1       Version = 1
)

func (Version) Descriptor 

func (Version) Descriptor() protoreflect.EnumDescriptor

func (Version) Enum 

func (x Version) Enum() *Version

func (Version) EnumDescriptor deprecated 

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

Deprecated: Use Version.Descriptor instead.

func (Version) Number 

func (x Version) Number() protoreflect.EnumNumber

func (Version) String 

func (x Version) String() string

func (Version) Type 

func (Version) Type() protoreflect.EnumType

type WorkloadInfo 

type WorkloadInfo struct {
	Name           string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace      string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ServiceAccount string `protobuf:"bytes,3,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadInfo) Descriptor deprecated 

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

Deprecated: Use WorkloadInfo.ProtoReflect.Descriptor instead.

func (*WorkloadInfo) GetName 

func (x *WorkloadInfo) GetName() string

func (*WorkloadInfo) GetNamespace 

func (x *WorkloadInfo) GetNamespace() string

func (*WorkloadInfo) GetServiceAccount 

func (x *WorkloadInfo) GetServiceAccount() string

func (*WorkloadInfo) ProtoMessage 

func (*WorkloadInfo) ProtoMessage()

func (*WorkloadInfo) ProtoReflect 

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

func (*WorkloadInfo) Reset 

func (x *WorkloadInfo) Reset()

func (*WorkloadInfo) String 

func (x *WorkloadInfo) String() string

type WorkloadRequest 

type WorkloadRequest struct {

	// Types that are assignable to Payload:
	//
	//	*WorkloadRequest_Add
	//	*WorkloadRequest_Keep
	//	*WorkloadRequest_Del
	//	*WorkloadRequest_SnapshotSent
	Payload isWorkloadRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Sent from CNI to ztunnel

func (*WorkloadRequest) Descriptor deprecated 

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

Deprecated: Use WorkloadRequest.ProtoReflect.Descriptor instead.

func (*WorkloadRequest) GetAdd 

func (x *WorkloadRequest) GetAdd() *AddWorkload

func (*WorkloadRequest) GetDel 

func (x *WorkloadRequest) GetDel() *DelWorkload

func (*WorkloadRequest) GetKeep 

func (x *WorkloadRequest) GetKeep() *KeepWorkload

func (*WorkloadRequest) GetPayload 

func (m *WorkloadRequest) GetPayload() isWorkloadRequest_Payload

func (*WorkloadRequest) GetSnapshotSent 

func (x *WorkloadRequest) GetSnapshotSent() *SnapshotSent

func (*WorkloadRequest) ProtoMessage 

func (*WorkloadRequest) ProtoMessage()

func (*WorkloadRequest) ProtoReflect 

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

func (*WorkloadRequest) Reset 

func (x *WorkloadRequest) Reset()

func (*WorkloadRequest) String 

func (x *WorkloadRequest) String() string

type WorkloadRequest_Add 

type WorkloadRequest_Add struct {
	Add *AddWorkload `protobuf:"bytes,1,opt,name=add,proto3,oneof"`
}

type WorkloadRequest_Del 

type WorkloadRequest_Del struct {
	Del *DelWorkload `protobuf:"bytes,2,opt,name=del,proto3,oneof"`
}

type WorkloadRequest_Keep 

type WorkloadRequest_Keep struct {
	Keep *KeepWorkload `protobuf:"bytes,5,opt,name=keep,proto3,oneof"`
}

type WorkloadRequest_SnapshotSent 

type WorkloadRequest_SnapshotSent struct {
	SnapshotSent *SnapshotSent `protobuf:"bytes,3,opt,name=snapshot_sent,json=snapshotSent,proto3,oneof"`
}

type WorkloadResponse 

type WorkloadResponse struct {

	// Types that are assignable to Payload:
	//
	//	*WorkloadResponse_Ack
	Payload isWorkloadResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Sent from ztunnel to CNI

func (*WorkloadResponse) Descriptor deprecated 

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

Deprecated: Use WorkloadResponse.ProtoReflect.Descriptor instead.

func (*WorkloadResponse) GetAck 

func (x *WorkloadResponse) GetAck() *Ack

func (*WorkloadResponse) GetPayload 

func (m *WorkloadResponse) GetPayload() isWorkloadResponse_Payload

func (*WorkloadResponse) ProtoMessage 

func (*WorkloadResponse) ProtoMessage()

func (*WorkloadResponse) ProtoReflect 

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

func (*WorkloadResponse) Reset 

func (x *WorkloadResponse) Reset()

func (*WorkloadResponse) String 

func (x *WorkloadResponse) String() string

type WorkloadResponse_Ack 

type WorkloadResponse_Ack struct {
	Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

type ZdsHello 

type ZdsHello struct {
	Version Version `protobuf:"varint,1,opt,name=version,proto3,enum=istio.workload.zds.Version" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ZdsHello) Descriptor deprecated 

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

Deprecated: Use ZdsHello.ProtoReflect.Descriptor instead.

func (*ZdsHello) GetVersion 

func (x *ZdsHello) GetVersion() Version

func (*ZdsHello) ProtoMessage 

func (*ZdsHello) ProtoMessage()

func (*ZdsHello) ProtoReflect 

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

func (*ZdsHello) Reset 

func (x *ZdsHello) Reset()

func (*ZdsHello) String 

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