 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- func RegisterDataplaneEventsServer(s grpc.ServiceRegistrar, srv DataplaneEventsServer)
- type DatapathPodMetadata
- func (*DatapathPodMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DatapathPodMetadata) GetApiVersion() DatapathPodMetadata_APIVersion
- func (x *DatapathPodMetadata) GetNodeName() string
- func (x *DatapathPodMetadata) GetPodName() string
- func (*DatapathPodMetadata) ProtoMessage()
- func (x *DatapathPodMetadata) ProtoReflect() protoreflect.Message
- func (x *DatapathPodMetadata) Reset()
- func (x *DatapathPodMetadata) String() string
 
- type DatapathPodMetadata_APIVersion
- func (DatapathPodMetadata_APIVersion) Descriptor() protoreflect.EnumDescriptor
- func (x DatapathPodMetadata_APIVersion) Enum() *DatapathPodMetadata_APIVersion
- func (DatapathPodMetadata_APIVersion) EnumDescriptor() ([]byte, []int)deprecated
- func (x DatapathPodMetadata_APIVersion) Number() protoreflect.EnumNumber
- func (x DatapathPodMetadata_APIVersion) String() string
- func (DatapathPodMetadata_APIVersion) Type() protoreflect.EnumType
 
- type DataplaneEventsClient
- type DataplaneEventsServer
- type DataplaneEvents_ConnectClient
- type DataplaneEvents_ConnectServer
- type Events
- type Events_EventType
- func (Events_EventType) Descriptor() protoreflect.EnumDescriptor
- func (x Events_EventType) Enum() *Events_EventType
- func (Events_EventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Events_EventType) Number() protoreflect.EnumNumber
- func (x Events_EventType) String() string
- func (Events_EventType) Type() protoreflect.EnumType
 
- type GoalState
- type UnimplementedDataplaneEventsServer
- type UnsafeDataplaneEventsServer
Constants ¶
This section is empty.
Variables ¶
var ( DatapathPodMetadata_APIVersion_name = map[int32]string{ 0: "V1", } DatapathPodMetadata_APIVersion_value = map[string]int32{ "V1": 0, } )
Enum value maps for DatapathPodMetadata_APIVersion.
var ( Events_EventType_name = map[int32]string{ 0: "GoalState", 1: "Hydration", } Events_EventType_value = map[string]int32{ "GoalState": 0, "Hydration": 1, } )
Enum value maps for Events_EventType.
var DataplaneEvents_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protos.DataplaneEvents", HandlerType: (*DataplaneEventsServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Connect", Handler: _DataplaneEvents_Connect_Handler, ServerStreams: true, }, }, Metadata: "transport.proto", }
DataplaneEvents_ServiceDesc is the grpc.ServiceDesc for DataplaneEvents service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_transport_proto protoreflect.FileDescriptor
    Functions ¶
func RegisterDataplaneEventsServer ¶
func RegisterDataplaneEventsServer(s grpc.ServiceRegistrar, srv DataplaneEventsServer)
Types ¶
type DatapathPodMetadata ¶
type DatapathPodMetadata struct {
	PodName    string                         `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`                                    // Daemonset Pod ID
	NodeName   string                         `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`                                 // Node name
	ApiVersion DatapathPodMetadata_APIVersion `protobuf:"varint,3,opt,name=apiVersion,proto3,enum=protos.DatapathPodMetadata_APIVersion" json:"apiVersion,omitempty"` // Controlplane API version to support backwards compatibility
	// contains filtered or unexported fields
}
    DatapathPodMetadata is the metadata for a datapath pod
        
          
            func (*DatapathPodMetadata) Descriptor
            deprecated
            
          
  
    
  
      
      func (*DatapathPodMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DatapathPodMetadata.ProtoReflect.Descriptor instead.
func (*DatapathPodMetadata) GetApiVersion ¶
func (x *DatapathPodMetadata) GetApiVersion() DatapathPodMetadata_APIVersion
func (*DatapathPodMetadata) GetNodeName ¶
func (x *DatapathPodMetadata) GetNodeName() string
func (*DatapathPodMetadata) GetPodName ¶
func (x *DatapathPodMetadata) GetPodName() string
func (*DatapathPodMetadata) ProtoMessage ¶
func (*DatapathPodMetadata) ProtoMessage()
func (*DatapathPodMetadata) ProtoReflect ¶
func (x *DatapathPodMetadata) ProtoReflect() protoreflect.Message
func (*DatapathPodMetadata) Reset ¶
func (x *DatapathPodMetadata) Reset()
func (*DatapathPodMetadata) String ¶
func (x *DatapathPodMetadata) String() string
type DatapathPodMetadata_APIVersion ¶
type DatapathPodMetadata_APIVersion int32
const (
	DatapathPodMetadata_V1 DatapathPodMetadata_APIVersion = 0
)
    func (DatapathPodMetadata_APIVersion) Descriptor ¶
func (DatapathPodMetadata_APIVersion) Descriptor() protoreflect.EnumDescriptor
func (DatapathPodMetadata_APIVersion) Enum ¶
func (x DatapathPodMetadata_APIVersion) Enum() *DatapathPodMetadata_APIVersion
        
          
            func (DatapathPodMetadata_APIVersion) EnumDescriptor
            deprecated
            
          
  
    
  
      
      func (DatapathPodMetadata_APIVersion) EnumDescriptor() ([]byte, []int)
Deprecated: Use DatapathPodMetadata_APIVersion.Descriptor instead.
func (DatapathPodMetadata_APIVersion) Number ¶
func (x DatapathPodMetadata_APIVersion) Number() protoreflect.EnumNumber
func (DatapathPodMetadata_APIVersion) String ¶
func (x DatapathPodMetadata_APIVersion) String() string
func (DatapathPodMetadata_APIVersion) Type ¶
func (DatapathPodMetadata_APIVersion) Type() protoreflect.EnumType
type DataplaneEventsClient ¶
type DataplaneEventsClient interface {
	Connect(ctx context.Context, in *DatapathPodMetadata, opts ...grpc.CallOption) (DataplaneEvents_ConnectClient, error)
}
    DataplaneEventsClient is the client API for DataplaneEvents 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 NewDataplaneEventsClient ¶
func NewDataplaneEventsClient(cc grpc.ClientConnInterface) DataplaneEventsClient
type DataplaneEventsServer ¶
type DataplaneEventsServer interface {
	Connect(*DatapathPodMetadata, DataplaneEvents_ConnectServer) error
	// contains filtered or unexported methods
}
    DataplaneEventsServer is the server API for DataplaneEvents service. All implementations must embed UnimplementedDataplaneEventsServer for forward compatibility
type DataplaneEvents_ConnectClient ¶
type DataplaneEvents_ConnectClient interface {
	Recv() (*Events, error)
	grpc.ClientStream
}
    type DataplaneEvents_ConnectServer ¶
type DataplaneEvents_ConnectServer interface {
	Send(*Events) error
	grpc.ServerStream
}
    type Events ¶
type Events struct {
	EventType Events_EventType `protobuf:"varint,1,opt,name=eventType,proto3,enum=protos.Events_EventType" json:"eventType,omitempty"`
	// Payload can contain one or more Event objects.
	Payload map[string]*GoalState `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}
    Events defines the operation (event type) and object type being streamed to the datapath client. A events message may carry one or more Event objects.
        
          
            func (*Events) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*Events) GetEventType ¶
func (x *Events) GetEventType() Events_EventType
func (*Events) GetPayload ¶
func (*Events) ProtoMessage ¶
func (*Events) ProtoMessage()
func (*Events) ProtoReflect ¶
func (x *Events) ProtoReflect() protoreflect.Message
type Events_EventType ¶
type Events_EventType int32
const ( Events_GoalState Events_EventType = 0 Events_Hydration Events_EventType = 1 )
func (Events_EventType) Descriptor ¶
func (Events_EventType) Descriptor() protoreflect.EnumDescriptor
func (Events_EventType) Enum ¶
func (x Events_EventType) Enum() *Events_EventType
        
          
            func (Events_EventType) EnumDescriptor
            deprecated
            
          
  
    
  
      
      func (Events_EventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Events_EventType.Descriptor instead.
func (Events_EventType) Number ¶
func (x Events_EventType) Number() protoreflect.EnumNumber
func (Events_EventType) String ¶
func (x Events_EventType) String() string
func (Events_EventType) Type ¶
func (Events_EventType) Type() protoreflect.EnumType
type GoalState ¶
type GoalState struct {
	// Data can contain one or more instances of IPSet or NetworkPolicy
	// objects.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}
    Event is a generic object that can be Created, Updated, Deleted by the controlplane.
        
          
            func (*GoalState) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*GoalState) ProtoMessage ¶
func (*GoalState) ProtoMessage()
func (*GoalState) ProtoReflect ¶
func (x *GoalState) ProtoReflect() protoreflect.Message
type UnimplementedDataplaneEventsServer ¶
type UnimplementedDataplaneEventsServer struct {
}
    UnimplementedDataplaneEventsServer must be embedded to have forward compatible implementations.
type UnsafeDataplaneEventsServer ¶
type UnsafeDataplaneEventsServer interface {
	// contains filtered or unexported methods
}
    UnsafeDataplaneEventsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataplaneEventsServer will result in compilation errors.