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 ¶
- Constants
- 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 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
- func (m *ControllerInfo) Validate() error
- func (m *ControllerInfo) ValidateAll() error
- type ControllerInfoMultiError
- type ControllerInfoServiceClient
- type ControllerInfoServiceServer
- type ControllerInfoValidationError
- func (e ControllerInfoValidationError) Cause() error
- func (e ControllerInfoValidationError) Error() string
- func (e ControllerInfoValidationError) ErrorName() string
- func (e ControllerInfoValidationError) Field() string
- func (e ControllerInfoValidationError) Key() bool
- func (e ControllerInfoValidationError) Reason() string
- 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
- func (m *OverlappingService) Validate() error
- func (m *OverlappingService) ValidateAll() error
- type OverlappingServiceMultiError
- type OverlappingServiceValidationError
- func (e OverlappingServiceValidationError) Cause() error
- func (e OverlappingServiceValidationError) Error() string
- func (e OverlappingServiceValidationError) ErrorName() string
- func (e OverlappingServiceValidationError) Field() string
- func (e OverlappingServiceValidationError) Key() bool
- func (e OverlappingServiceValidationError) Reason() string
- 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) GetAutoScaleKubernetesControlPoints() *v15.AutoScaleKubernetesControlPoints
- func (x *ReportRequest) GetControllerInfo() *ControllerInfo
- func (x *ReportRequest) GetFlowControlPoints() *v14.FlowControlPoints
- func (x *ReportRequest) GetHostInfo() *v1.HostInfo
- func (x *ReportRequest) GetInstallationMode() string
- 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
- func (m *ReportRequest) Validate() error
- func (m *ReportRequest) ValidateAll() error
- type ReportRequestMultiError
- type ReportRequestValidationError
- func (e ReportRequestValidationError) Cause() error
- func (e ReportRequestValidationError) Error() string
- func (e ReportRequestValidationError) ErrorName() string
- func (e ReportRequestValidationError) Field() string
- func (e ReportRequestValidationError) Key() bool
- func (e ReportRequestValidationError) Reason() string
- 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
- func (m *ReportResponse) Validate() error
- func (m *ReportResponse) ValidateAll() error
- type ReportResponseMultiError
- type ReportResponseValidationError
- func (e ReportResponseValidationError) Cause() error
- func (e ReportResponseValidationError) Error() string
- func (e ReportResponseValidationError) ErrorName() string
- func (e ReportResponseValidationError) Field() string
- func (e ReportResponseValidationError) Key() bool
- func (e ReportResponseValidationError) Reason() string
- 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
- func (m *Service) Validate() error
- func (m *Service) ValidateAll() error
- type ServiceMultiError
- type ServiceValidationError
- 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
- func (m *ServicesList) Validate() error
- func (m *ServicesList) ValidateAll() error
- type ServicesListMultiError
- type ServicesListValidationError
- func (e ServicesListValidationError) Cause() error
- func (e ServicesListValidationError) Error() string
- func (e ServicesListValidationError) ErrorName() string
- func (e ServicesListValidationError) Field() string
- func (e ServicesListValidationError) Key() bool
- func (e ServicesListValidationError) Reason() string
- type UnimplementedControllerInfoServiceServer
- type UnimplementedFluxNinjaServiceServer
- type UnsafeControllerInfoServiceServer
- type UnsafeFluxNinjaServiceServer
Constants ¶
const (
ControllerInfoService_GetControllerInfo_FullMethodName = "/aperture.fluxninja.v1.ControllerInfoService/GetControllerInfo"
)
const (
FluxNinjaService_Report_FullMethodName = "/aperture.fluxninja.v1.FluxNinjaService/Report"
)
Variables ¶
var ControllerInfoService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.fluxninja.v1.ControllerInfoService", HandlerType: (*ControllerInfoServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetControllerInfo", Handler: _ControllerInfoService_GetControllerInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/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_fluxninja_v1_heartbeat_proto protoreflect.FileDescriptor
var FluxNinjaService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.fluxninja.v1.FluxNinjaService", HandlerType: (*FluxNinjaServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Report", Handler: _FluxNinjaService_Report_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ControllerInfo ¶
type ControllerInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ControllerInfo) DeepCopy ¶
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 ¶
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 ¶
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
func (*ControllerInfo) Validate ¶ added in v1.2.0
func (m *ControllerInfo) Validate() error
Validate checks the field values on ControllerInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ControllerInfo) ValidateAll ¶ added in v1.2.0
func (m *ControllerInfo) ValidateAll() error
ValidateAll checks the field values on ControllerInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ControllerInfoMultiError, or nil if none found.
type ControllerInfoMultiError ¶ added in v1.2.0
type ControllerInfoMultiError []error
ControllerInfoMultiError is an error wrapping multiple validation errors returned by ControllerInfo.ValidateAll() if the designated constraints aren't met.
func (ControllerInfoMultiError) AllErrors ¶ added in v1.2.0
func (m ControllerInfoMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ControllerInfoMultiError) Error ¶ added in v1.2.0
func (m ControllerInfoMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ControllerInfoServiceClient ¶
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 ¶
func NewControllerInfoServiceClient(cc grpc.ClientConnInterface) ControllerInfoServiceClient
type ControllerInfoServiceServer ¶
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 ControllerInfoValidationError ¶ added in v1.2.0
type ControllerInfoValidationError struct {
// contains filtered or unexported fields
}
ControllerInfoValidationError is the validation error returned by ControllerInfo.Validate if the designated constraints aren't met.
func (ControllerInfoValidationError) Cause ¶ added in v1.2.0
func (e ControllerInfoValidationError) Cause() error
Cause function returns cause value.
func (ControllerInfoValidationError) Error ¶ added in v1.2.0
func (e ControllerInfoValidationError) Error() string
Error satisfies the builtin error interface
func (ControllerInfoValidationError) ErrorName ¶ added in v1.2.0
func (e ControllerInfoValidationError) ErrorName() string
ErrorName returns error name.
func (ControllerInfoValidationError) Field ¶ added in v1.2.0
func (e ControllerInfoValidationError) Field() string
Field function returns field value.
func (ControllerInfoValidationError) Key ¶ added in v1.2.0
func (e ControllerInfoValidationError) Key() bool
Key function returns key value.
func (ControllerInfoValidationError) Reason ¶ added in v1.2.0
func (e ControllerInfoValidationError) Reason() string
Reason function returns reason value.
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 ¶
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 ¶
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 ¶
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 ¶
func (in *OverlappingService) DeepCopyInto(out *OverlappingService)
DeepCopyInto supports using OverlappingService within kubernetes types, where deepcopy-gen is used.
func (*OverlappingService) Descriptor
deprecated
func (*OverlappingService) Descriptor() ([]byte, []int)
Deprecated: Use OverlappingService.ProtoReflect.Descriptor instead.
func (*OverlappingService) GetEntitiesCount ¶
func (x *OverlappingService) GetEntitiesCount() int32
func (*OverlappingService) GetService1 ¶
func (x *OverlappingService) GetService1() string
func (*OverlappingService) GetService2 ¶
func (x *OverlappingService) GetService2() string
func (*OverlappingService) MarshalJSON ¶
func (msg *OverlappingService) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*OverlappingService) ProtoMessage ¶
func (*OverlappingService) ProtoMessage()
func (*OverlappingService) ProtoReflect ¶
func (x *OverlappingService) ProtoReflect() protoreflect.Message
func (*OverlappingService) Reset ¶
func (x *OverlappingService) Reset()
func (*OverlappingService) String ¶
func (x *OverlappingService) String() string
func (*OverlappingService) UnmarshalJSON ¶
func (msg *OverlappingService) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*OverlappingService) Validate ¶ added in v1.2.0
func (m *OverlappingService) Validate() error
Validate checks the field values on OverlappingService with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*OverlappingService) ValidateAll ¶ added in v1.2.0
func (m *OverlappingService) ValidateAll() error
ValidateAll checks the field values on OverlappingService with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OverlappingServiceMultiError, or nil if none found.
type OverlappingServiceMultiError ¶ added in v1.2.0
type OverlappingServiceMultiError []error
OverlappingServiceMultiError is an error wrapping multiple validation errors returned by OverlappingService.ValidateAll() if the designated constraints aren't met.
func (OverlappingServiceMultiError) AllErrors ¶ added in v1.2.0
func (m OverlappingServiceMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (OverlappingServiceMultiError) Error ¶ added in v1.2.0
func (m OverlappingServiceMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type OverlappingServiceValidationError ¶ added in v1.2.0
type OverlappingServiceValidationError struct {
// contains filtered or unexported fields
}
OverlappingServiceValidationError is the validation error returned by OverlappingService.Validate if the designated constraints aren't met.
func (OverlappingServiceValidationError) Cause ¶ added in v1.2.0
func (e OverlappingServiceValidationError) Cause() error
Cause function returns cause value.
func (OverlappingServiceValidationError) Error ¶ added in v1.2.0
func (e OverlappingServiceValidationError) Error() string
Error satisfies the builtin error interface
func (OverlappingServiceValidationError) ErrorName ¶ added in v1.2.0
func (e OverlappingServiceValidationError) ErrorName() string
ErrorName returns error name.
func (OverlappingServiceValidationError) Field ¶ added in v1.2.0
func (e OverlappingServiceValidationError) Field() string
Field function returns field value.
func (OverlappingServiceValidationError) Key ¶ added in v1.2.0
func (e OverlappingServiceValidationError) Key() bool
Key function returns key value.
func (OverlappingServiceValidationError) Reason ¶ added in v1.2.0
func (e OverlappingServiceValidationError) Reason() string
Reason function returns reason value.
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"` FlowControlPoints *v14.FlowControlPoints `protobuf:"bytes,11,opt,name=flow_control_points,json=flowControlPoints,proto3" json:"flow_control_points,omitempty"` AutoScaleKubernetesControlPoints *v15.AutoScaleKubernetesControlPoints `` /* 164-byte string literal not displayed */ InstallationMode string `protobuf:"bytes,13,opt,name=installation_mode,json=installationMode,proto3" json:"installation_mode,omitempty"` // contains filtered or unexported fields }
func (*ReportRequest) DeepCopy ¶
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 ¶
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 ¶
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) GetAutoScaleKubernetesControlPoints ¶
func (x *ReportRequest) GetAutoScaleKubernetesControlPoints() *v15.AutoScaleKubernetesControlPoints
func (*ReportRequest) GetControllerInfo ¶
func (x *ReportRequest) GetControllerInfo() *ControllerInfo
func (*ReportRequest) GetFlowControlPoints ¶
func (x *ReportRequest) GetFlowControlPoints() *v14.FlowControlPoints
func (*ReportRequest) GetHostInfo ¶
func (x *ReportRequest) GetHostInfo() *v1.HostInfo
func (*ReportRequest) GetInstallationMode ¶
func (x *ReportRequest) GetInstallationMode() string
func (*ReportRequest) GetPeers ¶
func (x *ReportRequest) GetPeers() *v11.Peers
func (*ReportRequest) GetPolicies ¶
func (x *ReportRequest) GetPolicies() *v13.PolicyWrappers
func (*ReportRequest) GetProcessInfo ¶
func (x *ReportRequest) GetProcessInfo() *v1.ProcessInfo
func (*ReportRequest) GetServicesList ¶
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
func (*ReportRequest) Validate ¶ added in v1.2.0
func (m *ReportRequest) Validate() error
Validate checks the field values on ReportRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ReportRequest) ValidateAll ¶ added in v1.2.0
func (m *ReportRequest) ValidateAll() error
ValidateAll checks the field values on ReportRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReportRequestMultiError, or nil if none found.
type ReportRequestMultiError ¶ added in v1.2.0
type ReportRequestMultiError []error
ReportRequestMultiError is an error wrapping multiple validation errors returned by ReportRequest.ValidateAll() if the designated constraints aren't met.
func (ReportRequestMultiError) AllErrors ¶ added in v1.2.0
func (m ReportRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReportRequestMultiError) Error ¶ added in v1.2.0
func (m ReportRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReportRequestValidationError ¶ added in v1.2.0
type ReportRequestValidationError struct {
// contains filtered or unexported fields
}
ReportRequestValidationError is the validation error returned by ReportRequest.Validate if the designated constraints aren't met.
func (ReportRequestValidationError) Cause ¶ added in v1.2.0
func (e ReportRequestValidationError) Cause() error
Cause function returns cause value.
func (ReportRequestValidationError) Error ¶ added in v1.2.0
func (e ReportRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ReportRequestValidationError) ErrorName ¶ added in v1.2.0
func (e ReportRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ReportRequestValidationError) Field ¶ added in v1.2.0
func (e ReportRequestValidationError) Field() string
Field function returns field value.
func (ReportRequestValidationError) Key ¶ added in v1.2.0
func (e ReportRequestValidationError) Key() bool
Key function returns key value.
func (ReportRequestValidationError) Reason ¶ added in v1.2.0
func (e ReportRequestValidationError) Reason() string
Reason function returns reason value.
type ReportResponse ¶
type ReportResponse struct {
// contains filtered or unexported fields
}
ReportResponse is empty for now.
func (*ReportResponse) DeepCopy ¶
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 ¶
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 ¶
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
func (*ReportResponse) Validate ¶ added in v1.2.0
func (m *ReportResponse) Validate() error
Validate checks the field values on ReportResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ReportResponse) ValidateAll ¶ added in v1.2.0
func (m *ReportResponse) ValidateAll() error
ValidateAll checks the field values on ReportResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReportResponseMultiError, or nil if none found.
type ReportResponseMultiError ¶ added in v1.2.0
type ReportResponseMultiError []error
ReportResponseMultiError is an error wrapping multiple validation errors returned by ReportResponse.ValidateAll() if the designated constraints aren't met.
func (ReportResponseMultiError) AllErrors ¶ added in v1.2.0
func (m ReportResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReportResponseMultiError) Error ¶ added in v1.2.0
func (m ReportResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReportResponseValidationError ¶ added in v1.2.0
type ReportResponseValidationError struct {
// contains filtered or unexported fields
}
ReportResponseValidationError is the validation error returned by ReportResponse.Validate if the designated constraints aren't met.
func (ReportResponseValidationError) Cause ¶ added in v1.2.0
func (e ReportResponseValidationError) Cause() error
Cause function returns cause value.
func (ReportResponseValidationError) Error ¶ added in v1.2.0
func (e ReportResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ReportResponseValidationError) ErrorName ¶ added in v1.2.0
func (e ReportResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ReportResponseValidationError) Field ¶ added in v1.2.0
func (e ReportResponseValidationError) Field() string
Field function returns field value.
func (ReportResponseValidationError) Key ¶ added in v1.2.0
func (e ReportResponseValidationError) Key() bool
Key function returns key value.
func (ReportResponseValidationError) Reason ¶ added in v1.2.0
func (e ReportResponseValidationError) Reason() string
Reason function returns reason value.
type Service ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Service. Required by controller-gen.
func (*Service) DeepCopyInterface ¶
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 ¶
DeepCopyInto supports using Service within kubernetes types, where deepcopy-gen is used.
func (*Service) Descriptor
deprecated
func (*Service) GetEntitiesCount ¶
func (*Service) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
func (*Service) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Service) Validate ¶ added in v1.2.0
Validate checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Service) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServiceMultiError, or nil if none found.
type ServiceMultiError ¶ added in v1.2.0
type ServiceMultiError []error
ServiceMultiError is an error wrapping multiple validation errors returned by Service.ValidateAll() if the designated constraints aren't met.
func (ServiceMultiError) AllErrors ¶ added in v1.2.0
func (m ServiceMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServiceMultiError) Error ¶ added in v1.2.0
func (m ServiceMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServiceValidationError ¶ added in v1.2.0
type ServiceValidationError struct {
// contains filtered or unexported fields
}
ServiceValidationError is the validation error returned by Service.Validate if the designated constraints aren't met.
func (ServiceValidationError) Cause ¶ added in v1.2.0
func (e ServiceValidationError) Cause() error
Cause function returns cause value.
func (ServiceValidationError) Error ¶ added in v1.2.0
func (e ServiceValidationError) Error() string
Error satisfies the builtin error interface
func (ServiceValidationError) ErrorName ¶ added in v1.2.0
func (e ServiceValidationError) ErrorName() string
ErrorName returns error name.
func (ServiceValidationError) Field ¶ added in v1.2.0
func (e ServiceValidationError) Field() string
Field function returns field value.
func (ServiceValidationError) Key ¶ added in v1.2.0
func (e ServiceValidationError) Key() bool
Key function returns key value.
func (ServiceValidationError) Reason ¶ added in v1.2.0
func (e ServiceValidationError) Reason() string
Reason function returns reason value.
type ServicesList ¶
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 ¶
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 ¶
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 ¶
func (in *ServicesList) DeepCopyInto(out *ServicesList)
DeepCopyInto supports using ServicesList within kubernetes types, where deepcopy-gen is used.
func (*ServicesList) Descriptor
deprecated
func (*ServicesList) Descriptor() ([]byte, []int)
Deprecated: Use ServicesList.ProtoReflect.Descriptor instead.
func (*ServicesList) GetOverlappingServices ¶
func (x *ServicesList) GetOverlappingServices() []*OverlappingService
func (*ServicesList) GetServices ¶
func (x *ServicesList) GetServices() []*Service
func (*ServicesList) MarshalJSON ¶
func (msg *ServicesList) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*ServicesList) ProtoMessage ¶
func (*ServicesList) ProtoMessage()
func (*ServicesList) ProtoReflect ¶
func (x *ServicesList) ProtoReflect() protoreflect.Message
func (*ServicesList) Reset ¶
func (x *ServicesList) Reset()
func (*ServicesList) String ¶
func (x *ServicesList) String() string
func (*ServicesList) UnmarshalJSON ¶
func (msg *ServicesList) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*ServicesList) Validate ¶ added in v1.2.0
func (m *ServicesList) Validate() error
Validate checks the field values on ServicesList with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ServicesList) ValidateAll ¶ added in v1.2.0
func (m *ServicesList) ValidateAll() error
ValidateAll checks the field values on ServicesList with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServicesListMultiError, or nil if none found.
type ServicesListMultiError ¶ added in v1.2.0
type ServicesListMultiError []error
ServicesListMultiError is an error wrapping multiple validation errors returned by ServicesList.ValidateAll() if the designated constraints aren't met.
func (ServicesListMultiError) AllErrors ¶ added in v1.2.0
func (m ServicesListMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServicesListMultiError) Error ¶ added in v1.2.0
func (m ServicesListMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServicesListValidationError ¶ added in v1.2.0
type ServicesListValidationError struct {
// contains filtered or unexported fields
}
ServicesListValidationError is the validation error returned by ServicesList.Validate if the designated constraints aren't met.
func (ServicesListValidationError) Cause ¶ added in v1.2.0
func (e ServicesListValidationError) Cause() error
Cause function returns cause value.
func (ServicesListValidationError) Error ¶ added in v1.2.0
func (e ServicesListValidationError) Error() string
Error satisfies the builtin error interface
func (ServicesListValidationError) ErrorName ¶ added in v1.2.0
func (e ServicesListValidationError) ErrorName() string
ErrorName returns error name.
func (ServicesListValidationError) Field ¶ added in v1.2.0
func (e ServicesListValidationError) Field() string
Field function returns field value.
func (ServicesListValidationError) Key ¶ added in v1.2.0
func (e ServicesListValidationError) Key() bool
Key function returns key value.
func (ServicesListValidationError) Reason ¶ added in v1.2.0
func (e ServicesListValidationError) Reason() string
Reason function returns reason value.
type UnimplementedControllerInfoServiceServer ¶
type UnimplementedControllerInfoServiceServer struct { }
UnimplementedControllerInfoServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedControllerInfoServiceServer) GetControllerInfo ¶
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 ¶
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.