Documentation ¶
Overview ¶
Package fluxninjav1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Code generated by protoc-gen-deepcopy. DO NOT EDIT.
Index ¶
- Variables
- func RegisterControllerInfoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterControllerInfoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControllerInfoServiceClient) error
- func RegisterControllerInfoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterControllerInfoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControllerInfoServiceServer) error
- func RegisterControllerInfoServiceServer(s grpc.ServiceRegistrar, srv ControllerInfoServiceServer)
- func RegisterFluxNinjaServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterFluxNinjaServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FluxNinjaServiceClient) error
- func RegisterFluxNinjaServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterFluxNinjaServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FluxNinjaServiceServer) error
- func RegisterFluxNinjaServiceServer(s grpc.ServiceRegistrar, srv FluxNinjaServiceServer)
- type ControlPoint
- func (in *ControlPoint) DeepCopy() *ControlPoint
- func (in *ControlPoint) DeepCopyInterface() interface{}
- func (in *ControlPoint) DeepCopyInto(out *ControlPoint)
- func (*ControlPoint) Descriptor() ([]byte, []int)deprecated
- func (x *ControlPoint) GetName() string
- func (x *ControlPoint) GetServiceName() string
- func (msg *ControlPoint) MarshalJSON() ([]byte, error)
- func (*ControlPoint) ProtoMessage()
- func (x *ControlPoint) ProtoReflect() protoreflect.Message
- func (x *ControlPoint) Reset()
- func (x *ControlPoint) String() string
- func (msg *ControlPoint) UnmarshalJSON(b []byte) error
- type ControllerInfo
- func (in *ControllerInfo) DeepCopy() *ControllerInfo
- func (in *ControllerInfo) DeepCopyInterface() interface{}
- func (in *ControllerInfo) DeepCopyInto(out *ControllerInfo)
- func (*ControllerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ControllerInfo) GetId() string
- func (msg *ControllerInfo) MarshalJSON() ([]byte, error)
- func (*ControllerInfo) ProtoMessage()
- func (x *ControllerInfo) ProtoReflect() protoreflect.Message
- func (x *ControllerInfo) Reset()
- func (x *ControllerInfo) String() string
- func (msg *ControllerInfo) UnmarshalJSON(b []byte) error
- type ControllerInfoServiceClient
- type ControllerInfoServiceServer
- type FluxNinjaServiceClient
- type FluxNinjaServiceServer
- type OverlappingService
- func (in *OverlappingService) DeepCopy() *OverlappingService
- func (in *OverlappingService) DeepCopyInterface() interface{}
- func (in *OverlappingService) DeepCopyInto(out *OverlappingService)
- func (*OverlappingService) Descriptor() ([]byte, []int)deprecated
- func (x *OverlappingService) GetEntitiesCount() int32
- func (x *OverlappingService) GetService1() string
- func (x *OverlappingService) GetService2() string
- func (msg *OverlappingService) MarshalJSON() ([]byte, error)
- func (*OverlappingService) ProtoMessage()
- func (x *OverlappingService) ProtoReflect() protoreflect.Message
- func (x *OverlappingService) Reset()
- func (x *OverlappingService) String() string
- func (msg *OverlappingService) UnmarshalJSON(b []byte) error
- type ReportRequest
- func (in *ReportRequest) DeepCopy() *ReportRequest
- func (in *ReportRequest) DeepCopyInterface() interface{}
- func (in *ReportRequest) DeepCopyInto(out *ReportRequest)
- func (*ReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportRequest) GetAgentGroup() string
- func (x *ReportRequest) GetAllStatuses() *v12.GroupStatus
- func (x *ReportRequest) GetControlPoints() []*ControlPoint
- func (x *ReportRequest) GetControllerInfo() *ControllerInfo
- func (x *ReportRequest) GetHostInfo() *v1.HostInfo
- func (x *ReportRequest) GetPeers() *v11.Peers
- func (x *ReportRequest) GetPolicies() *v13.PolicyWrappers
- func (x *ReportRequest) GetProcessInfo() *v1.ProcessInfo
- func (x *ReportRequest) GetServicesList() *ServicesList
- func (x *ReportRequest) GetVersionInfo() *v1.VersionInfo
- func (msg *ReportRequest) MarshalJSON() ([]byte, error)
- func (*ReportRequest) ProtoMessage()
- func (x *ReportRequest) ProtoReflect() protoreflect.Message
- func (x *ReportRequest) Reset()
- func (x *ReportRequest) String() string
- func (msg *ReportRequest) UnmarshalJSON(b []byte) error
- type ReportResponse
- func (in *ReportResponse) DeepCopy() *ReportResponse
- func (in *ReportResponse) DeepCopyInterface() interface{}
- func (in *ReportResponse) DeepCopyInto(out *ReportResponse)
- func (*ReportResponse) Descriptor() ([]byte, []int)deprecated
- func (msg *ReportResponse) MarshalJSON() ([]byte, error)
- func (*ReportResponse) ProtoMessage()
- func (x *ReportResponse) ProtoReflect() protoreflect.Message
- func (x *ReportResponse) Reset()
- func (x *ReportResponse) String() string
- func (msg *ReportResponse) UnmarshalJSON(b []byte) error
- type Service
- func (in *Service) DeepCopy() *Service
- func (in *Service) DeepCopyInterface() interface{}
- func (in *Service) DeepCopyInto(out *Service)
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetEntitiesCount() int32
- func (x *Service) GetName() string
- func (msg *Service) MarshalJSON() ([]byte, error)
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- func (msg *Service) UnmarshalJSON(b []byte) error
- type ServicesList
- func (in *ServicesList) DeepCopy() *ServicesList
- func (in *ServicesList) DeepCopyInterface() interface{}
- func (in *ServicesList) DeepCopyInto(out *ServicesList)
- func (*ServicesList) Descriptor() ([]byte, []int)deprecated
- func (x *ServicesList) GetOverlappingServices() []*OverlappingService
- func (x *ServicesList) GetServices() []*Service
- func (msg *ServicesList) MarshalJSON() ([]byte, error)
- func (*ServicesList) ProtoMessage()
- func (x *ServicesList) ProtoReflect() protoreflect.Message
- func (x *ServicesList) Reset()
- func (x *ServicesList) String() string
- func (msg *ServicesList) UnmarshalJSON(b []byte) error
- type UnimplementedControllerInfoServiceServer
- type UnimplementedFluxNinjaServiceServer
- type UnsafeControllerInfoServiceServer
- type UnsafeFluxNinjaServiceServer
Constants ¶
This section is empty.
Variables ¶
var ControllerInfoService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.plugins.fluxninja.v1.ControllerInfoService", HandlerType: (*ControllerInfoServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetControllerInfo", Handler: _ControllerInfoService_GetControllerInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/plugins/fluxninja/v1/heartbeat.proto", }
ControllerInfoService_ServiceDesc is the grpc.ServiceDesc for ControllerInfoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_aperture_plugins_fluxninja_v1_heartbeat_proto protoreflect.FileDescriptor
var FluxNinjaService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.plugins.fluxninja.v1.FluxNinjaService", HandlerType: (*FluxNinjaServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Report", Handler: _FluxNinjaService_Report_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/plugins/fluxninja/v1/heartbeat.proto", }
FluxNinjaService_ServiceDesc is the grpc.ServiceDesc for FluxNinjaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterControllerInfoServiceHandler ¶ added in v0.3.0
func RegisterControllerInfoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterControllerInfoServiceHandler registers the http handlers for service ControllerInfoService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterControllerInfoServiceHandlerClient ¶ added in v0.3.0
func RegisterControllerInfoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControllerInfoServiceClient) error
RegisterControllerInfoServiceHandlerClient registers the http handlers for service ControllerInfoService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ControllerInfoServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ControllerInfoServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ControllerInfoServiceClient" to call the correct interceptors.
func RegisterControllerInfoServiceHandlerFromEndpoint ¶ added in v0.3.0
func RegisterControllerInfoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterControllerInfoServiceHandlerFromEndpoint is same as RegisterControllerInfoServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterControllerInfoServiceHandlerServer ¶ added in v0.3.0
func RegisterControllerInfoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControllerInfoServiceServer) error
RegisterControllerInfoServiceHandlerServer registers the http handlers for service ControllerInfoService to "mux". UnaryRPC :call ControllerInfoServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterControllerInfoServiceHandlerFromEndpoint instead.
func RegisterControllerInfoServiceServer ¶ added in v0.3.0
func RegisterControllerInfoServiceServer(s grpc.ServiceRegistrar, srv ControllerInfoServiceServer)
func RegisterFluxNinjaServiceHandler ¶
func RegisterFluxNinjaServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterFluxNinjaServiceHandler registers the http handlers for service FluxNinjaService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterFluxNinjaServiceHandlerClient ¶
func RegisterFluxNinjaServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FluxNinjaServiceClient) error
RegisterFluxNinjaServiceHandlerClient registers the http handlers for service FluxNinjaService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FluxNinjaServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FluxNinjaServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FluxNinjaServiceClient" to call the correct interceptors.
func RegisterFluxNinjaServiceHandlerFromEndpoint ¶
func RegisterFluxNinjaServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterFluxNinjaServiceHandlerFromEndpoint is same as RegisterFluxNinjaServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterFluxNinjaServiceHandlerServer ¶
func RegisterFluxNinjaServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FluxNinjaServiceServer) error
RegisterFluxNinjaServiceHandlerServer registers the http handlers for service FluxNinjaService to "mux". UnaryRPC :call FluxNinjaServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFluxNinjaServiceHandlerFromEndpoint instead.
func RegisterFluxNinjaServiceServer ¶
func RegisterFluxNinjaServiceServer(s grpc.ServiceRegistrar, srv FluxNinjaServiceServer)
Types ¶
type ControlPoint ¶ added in v0.12.0
type ControlPoint struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // contains filtered or unexported fields }
ControlPoint contains info about a control point on a given service.
func (*ControlPoint) DeepCopy ¶ added in v0.12.0
func (in *ControlPoint) DeepCopy() *ControlPoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControlPoint. Required by controller-gen.
func (*ControlPoint) DeepCopyInterface ¶ added in v0.12.0
func (in *ControlPoint) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ControlPoint. Required by controller-gen.
func (*ControlPoint) DeepCopyInto ¶ added in v0.12.0
func (in *ControlPoint) DeepCopyInto(out *ControlPoint)
DeepCopyInto supports using ControlPoint within kubernetes types, where deepcopy-gen is used.
func (*ControlPoint) Descriptor
deprecated
added in
v0.12.0
func (*ControlPoint) Descriptor() ([]byte, []int)
Deprecated: Use ControlPoint.ProtoReflect.Descriptor instead.
func (*ControlPoint) GetName ¶ added in v0.12.0
func (x *ControlPoint) GetName() string
func (*ControlPoint) GetServiceName ¶ added in v0.12.0
func (x *ControlPoint) GetServiceName() string
func (*ControlPoint) MarshalJSON ¶ added in v0.12.0
func (msg *ControlPoint) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ControlPoint) ProtoMessage ¶ added in v0.12.0
func (*ControlPoint) ProtoMessage()
func (*ControlPoint) ProtoReflect ¶ added in v0.12.0
func (x *ControlPoint) ProtoReflect() protoreflect.Message
func (*ControlPoint) Reset ¶ added in v0.12.0
func (x *ControlPoint) Reset()
func (*ControlPoint) String ¶ added in v0.12.0
func (x *ControlPoint) String() string
func (*ControlPoint) UnmarshalJSON ¶ added in v0.12.0
func (msg *ControlPoint) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type ControllerInfo ¶
type ControllerInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ControllerInfo) DeepCopy ¶ added in v0.1.2
func (in *ControllerInfo) DeepCopy() *ControllerInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerInfo. Required by controller-gen.
func (*ControllerInfo) DeepCopyInterface ¶ added in v0.1.2
func (in *ControllerInfo) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ControllerInfo. Required by controller-gen.
func (*ControllerInfo) DeepCopyInto ¶ added in v0.1.2
func (in *ControllerInfo) DeepCopyInto(out *ControllerInfo)
DeepCopyInto supports using ControllerInfo within kubernetes types, where deepcopy-gen is used.
func (*ControllerInfo) Descriptor
deprecated
func (*ControllerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ControllerInfo.ProtoReflect.Descriptor instead.
func (*ControllerInfo) GetId ¶
func (x *ControllerInfo) GetId() string
func (*ControllerInfo) MarshalJSON ¶
func (msg *ControllerInfo) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ControllerInfo) ProtoMessage ¶
func (*ControllerInfo) ProtoMessage()
func (*ControllerInfo) ProtoReflect ¶
func (x *ControllerInfo) ProtoReflect() protoreflect.Message
func (*ControllerInfo) Reset ¶
func (x *ControllerInfo) Reset()
func (*ControllerInfo) String ¶
func (x *ControllerInfo) String() string
func (*ControllerInfo) UnmarshalJSON ¶
func (msg *ControllerInfo) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type ControllerInfoServiceClient ¶ added in v0.3.0
type ControllerInfoServiceClient interface {
GetControllerInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ControllerInfo, error)
}
ControllerInfoServiceClient is the client API for ControllerInfoService 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 NewControllerInfoServiceClient ¶ added in v0.3.0
func NewControllerInfoServiceClient(cc grpc.ClientConnInterface) ControllerInfoServiceClient
type ControllerInfoServiceServer ¶ added in v0.3.0
type ControllerInfoServiceServer interface {
GetControllerInfo(context.Context, *emptypb.Empty) (*ControllerInfo, error)
}
ControllerInfoServiceServer is the server API for ControllerInfoService service. All implementations should embed UnimplementedControllerInfoServiceServer for forward compatibility
type FluxNinjaServiceClient ¶
type FluxNinjaServiceClient interface { // Report accepts information about agents' health and applied configurations/policies. Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error) }
FluxNinjaServiceClient is the client API for FluxNinjaService 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 NewFluxNinjaServiceClient ¶
func NewFluxNinjaServiceClient(cc grpc.ClientConnInterface) FluxNinjaServiceClient
type FluxNinjaServiceServer ¶
type FluxNinjaServiceServer interface { // Report accepts information about agents' health and applied configurations/policies. Report(context.Context, *ReportRequest) (*ReportResponse, error) }
FluxNinjaServiceServer is the server API for FluxNinjaService service. All implementations should embed UnimplementedFluxNinjaServiceServer for forward compatibility
type OverlappingService ¶ added in v0.2.1
type OverlappingService struct { Service1 string `protobuf:"bytes,1,opt,name=service1,proto3" json:"service1,omitempty"` Service2 string `protobuf:"bytes,2,opt,name=service2,proto3" json:"service2,omitempty"` EntitiesCount int32 `protobuf:"varint,3,opt,name=entities_count,json=entitiesCount,proto3" json:"entities_count,omitempty"` // contains filtered or unexported fields }
OverlappingService contains info about a service that overlaps with another one.
func (*OverlappingService) DeepCopy ¶ added in v0.2.1
func (in *OverlappingService) DeepCopy() *OverlappingService
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OverlappingService. Required by controller-gen.
func (*OverlappingService) DeepCopyInterface ¶ added in v0.2.1
func (in *OverlappingService) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new OverlappingService. Required by controller-gen.
func (*OverlappingService) DeepCopyInto ¶ added in v0.2.1
func (in *OverlappingService) DeepCopyInto(out *OverlappingService)
DeepCopyInto supports using OverlappingService within kubernetes types, where deepcopy-gen is used.
func (*OverlappingService) Descriptor
deprecated
added in
v0.2.1
func (*OverlappingService) Descriptor() ([]byte, []int)
Deprecated: Use OverlappingService.ProtoReflect.Descriptor instead.
func (*OverlappingService) GetEntitiesCount ¶ added in v0.2.1
func (x *OverlappingService) GetEntitiesCount() int32
func (*OverlappingService) GetService1 ¶ added in v0.2.1
func (x *OverlappingService) GetService1() string
func (*OverlappingService) GetService2 ¶ added in v0.2.1
func (x *OverlappingService) GetService2() string
func (*OverlappingService) MarshalJSON ¶ added in v0.2.1
func (msg *OverlappingService) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*OverlappingService) ProtoMessage ¶ added in v0.2.1
func (*OverlappingService) ProtoMessage()
func (*OverlappingService) ProtoReflect ¶ added in v0.2.1
func (x *OverlappingService) ProtoReflect() protoreflect.Message
func (*OverlappingService) Reset ¶ added in v0.2.1
func (x *OverlappingService) Reset()
func (*OverlappingService) String ¶ added in v0.2.1
func (x *OverlappingService) String() string
func (*OverlappingService) UnmarshalJSON ¶ added in v0.2.1
func (msg *OverlappingService) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type ReportRequest ¶
type ReportRequest struct { VersionInfo *v1.VersionInfo `protobuf:"bytes,1,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` ProcessInfo *v1.ProcessInfo `protobuf:"bytes,2,opt,name=process_info,json=processInfo,proto3" json:"process_info,omitempty"` HostInfo *v1.HostInfo `protobuf:"bytes,3,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"` AgentGroup string `protobuf:"bytes,4,opt,name=agent_group,json=agentGroup,proto3" json:"agent_group,omitempty"` ControllerInfo *ControllerInfo `protobuf:"bytes,5,opt,name=controller_info,json=controllerInfo,proto3" json:"controller_info,omitempty"` Peers *v11.Peers `protobuf:"bytes,6,opt,name=peers,proto3" json:"peers,omitempty"` ServicesList *ServicesList `protobuf:"bytes,8,opt,name=services_list,json=servicesList,proto3" json:"services_list,omitempty"` AllStatuses *v12.GroupStatus `protobuf:"bytes,9,opt,name=all_statuses,json=allStatuses,proto3" json:"all_statuses,omitempty"` Policies *v13.PolicyWrappers `protobuf:"bytes,10,opt,name=policies,proto3" json:"policies,omitempty"` ControlPoints []*ControlPoint `protobuf:"bytes,11,rep,name=control_points,json=controlPoints,proto3" json:"control_points,omitempty"` // contains filtered or unexported fields }
func (*ReportRequest) DeepCopy ¶ added in v0.1.2
func (in *ReportRequest) DeepCopy() *ReportRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReportRequest. Required by controller-gen.
func (*ReportRequest) DeepCopyInterface ¶ added in v0.1.2
func (in *ReportRequest) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ReportRequest. Required by controller-gen.
func (*ReportRequest) DeepCopyInto ¶ added in v0.1.2
func (in *ReportRequest) DeepCopyInto(out *ReportRequest)
DeepCopyInto supports using ReportRequest within kubernetes types, where deepcopy-gen is used.
func (*ReportRequest) Descriptor
deprecated
func (*ReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportRequest.ProtoReflect.Descriptor instead.
func (*ReportRequest) GetAgentGroup ¶
func (x *ReportRequest) GetAgentGroup() string
func (*ReportRequest) GetAllStatuses ¶
func (x *ReportRequest) GetAllStatuses() *v12.GroupStatus
func (*ReportRequest) GetControlPoints ¶ added in v0.12.0
func (x *ReportRequest) GetControlPoints() []*ControlPoint
func (*ReportRequest) GetControllerInfo ¶
func (x *ReportRequest) GetControllerInfo() *ControllerInfo
func (*ReportRequest) GetHostInfo ¶
func (x *ReportRequest) GetHostInfo() *v1.HostInfo
func (*ReportRequest) GetPeers ¶
func (x *ReportRequest) GetPeers() *v11.Peers
func (*ReportRequest) GetPolicies ¶ added in v0.5.0
func (x *ReportRequest) GetPolicies() *v13.PolicyWrappers
func (*ReportRequest) GetProcessInfo ¶
func (x *ReportRequest) GetProcessInfo() *v1.ProcessInfo
func (*ReportRequest) GetServicesList ¶ added in v0.1.2
func (x *ReportRequest) GetServicesList() *ServicesList
func (*ReportRequest) GetVersionInfo ¶
func (x *ReportRequest) GetVersionInfo() *v1.VersionInfo
func (*ReportRequest) MarshalJSON ¶
func (msg *ReportRequest) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ReportRequest) ProtoMessage ¶
func (*ReportRequest) ProtoMessage()
func (*ReportRequest) ProtoReflect ¶
func (x *ReportRequest) ProtoReflect() protoreflect.Message
func (*ReportRequest) Reset ¶
func (x *ReportRequest) Reset()
func (*ReportRequest) String ¶
func (x *ReportRequest) String() string
func (*ReportRequest) UnmarshalJSON ¶
func (msg *ReportRequest) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type ReportResponse ¶
type ReportResponse struct {
// contains filtered or unexported fields
}
ReportResponse is empty for now.
func (*ReportResponse) DeepCopy ¶ added in v0.1.2
func (in *ReportResponse) DeepCopy() *ReportResponse
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReportResponse. Required by controller-gen.
func (*ReportResponse) DeepCopyInterface ¶ added in v0.1.2
func (in *ReportResponse) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ReportResponse. Required by controller-gen.
func (*ReportResponse) DeepCopyInto ¶ added in v0.1.2
func (in *ReportResponse) DeepCopyInto(out *ReportResponse)
DeepCopyInto supports using ReportResponse within kubernetes types, where deepcopy-gen is used.
func (*ReportResponse) Descriptor
deprecated
func (*ReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportResponse.ProtoReflect.Descriptor instead.
func (*ReportResponse) MarshalJSON ¶
func (msg *ReportResponse) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ReportResponse) ProtoMessage ¶
func (*ReportResponse) ProtoMessage()
func (*ReportResponse) ProtoReflect ¶
func (x *ReportResponse) ProtoReflect() protoreflect.Message
func (*ReportResponse) Reset ¶
func (x *ReportResponse) Reset()
func (*ReportResponse) String ¶
func (x *ReportResponse) String() string
func (*ReportResponse) UnmarshalJSON ¶
func (msg *ReportResponse) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type Service ¶ added in v0.2.1
type Service struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` EntitiesCount int32 `protobuf:"varint,2,opt,name=entities_count,json=entitiesCount,proto3" json:"entities_count,omitempty"` // contains filtered or unexported fields }
Service contains information about single service discovered in agent group by a particular agent.
func (*Service) DeepCopy ¶ added in v0.2.1
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Service. Required by controller-gen.
func (*Service) DeepCopyInterface ¶ added in v0.2.1
func (in *Service) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Service. Required by controller-gen.
func (*Service) DeepCopyInto ¶ added in v0.2.1
DeepCopyInto supports using Service within kubernetes types, where deepcopy-gen is used.
func (*Service) Descriptor
deprecated
added in
v0.2.1
func (*Service) GetEntitiesCount ¶ added in v0.2.1
func (*Service) MarshalJSON ¶ added in v0.2.1
MarshalJSON implements json.Marshaler
func (*Service) ProtoMessage ¶ added in v0.2.1
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶ added in v0.2.1
func (x *Service) ProtoReflect() protoreflect.Message
func (*Service) UnmarshalJSON ¶ added in v0.2.1
UnmarshalJSON implements json.Unmarshaler
type ServicesList ¶ added in v0.2.1
type ServicesList struct { Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` OverlappingServices []*OverlappingService `protobuf:"bytes,2,rep,name=overlapping_services,json=overlappingServices,proto3" json:"overlapping_services,omitempty"` // contains filtered or unexported fields }
func (*ServicesList) DeepCopy ¶ added in v0.2.1
func (in *ServicesList) DeepCopy() *ServicesList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServicesList. Required by controller-gen.
func (*ServicesList) DeepCopyInterface ¶ added in v0.2.1
func (in *ServicesList) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ServicesList. Required by controller-gen.
func (*ServicesList) DeepCopyInto ¶ added in v0.2.1
func (in *ServicesList) DeepCopyInto(out *ServicesList)
DeepCopyInto supports using ServicesList within kubernetes types, where deepcopy-gen is used.
func (*ServicesList) Descriptor
deprecated
added in
v0.2.1
func (*ServicesList) Descriptor() ([]byte, []int)
Deprecated: Use ServicesList.ProtoReflect.Descriptor instead.
func (*ServicesList) GetOverlappingServices ¶ added in v0.2.1
func (x *ServicesList) GetOverlappingServices() []*OverlappingService
func (*ServicesList) GetServices ¶ added in v0.2.1
func (x *ServicesList) GetServices() []*Service
func (*ServicesList) MarshalJSON ¶ added in v0.2.1
func (msg *ServicesList) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ServicesList) ProtoMessage ¶ added in v0.2.1
func (*ServicesList) ProtoMessage()
func (*ServicesList) ProtoReflect ¶ added in v0.2.1
func (x *ServicesList) ProtoReflect() protoreflect.Message
func (*ServicesList) Reset ¶ added in v0.2.1
func (x *ServicesList) Reset()
func (*ServicesList) String ¶ added in v0.2.1
func (x *ServicesList) String() string
func (*ServicesList) UnmarshalJSON ¶ added in v0.2.1
func (msg *ServicesList) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type UnimplementedControllerInfoServiceServer ¶ added in v0.3.0
type UnimplementedControllerInfoServiceServer struct { }
UnimplementedControllerInfoServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedControllerInfoServiceServer) GetControllerInfo ¶ added in v0.3.0
func (UnimplementedControllerInfoServiceServer) GetControllerInfo(context.Context, *emptypb.Empty) (*ControllerInfo, error)
type UnimplementedFluxNinjaServiceServer ¶
type UnimplementedFluxNinjaServiceServer struct { }
UnimplementedFluxNinjaServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedFluxNinjaServiceServer) Report ¶
func (UnimplementedFluxNinjaServiceServer) Report(context.Context, *ReportRequest) (*ReportResponse, error)
type UnsafeControllerInfoServiceServer ¶ added in v0.3.0
type UnsafeControllerInfoServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControllerInfoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerInfoServiceServer will result in compilation errors.
type UnsafeFluxNinjaServiceServer ¶
type UnsafeFluxNinjaServiceServer interface {
// contains filtered or unexported methods
}
UnsafeFluxNinjaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FluxNinjaServiceServer will result in compilation errors.