fluxninjav1

package
v0.2.2-rc.1 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2022 License: AGPL-3.0 Imports: 21 Imported by: 0

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

This section is empty.

Variables

View Source 
var File_aperture_plugins_fluxninja_v1_heartbeat_proto protoreflect.FileDescriptor
View Source 
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 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 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 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"`
	// 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) 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) 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 

func (in *Service) DeepCopy() *Service

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 

func (in *Service) DeepCopyInto(out *Service)

DeepCopyInto supports using Service within kubernetes types, where deepcopy-gen is used.

func (*Service) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetEntitiesCount added in v0.2.1 

func (x *Service) GetEntitiesCount() int32

func (*Service) GetName added in v0.2.1 

func (x *Service) GetName() string

func (*Service) MarshalJSON added in v0.2.1 

func (msg *Service) MarshalJSON() ([]byte, error)

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) Reset added in v0.2.1 

func (x *Service) Reset()

func (*Service) String added in v0.2.1 

func (x *Service) String() string

func (*Service) UnmarshalJSON added in v0.2.1 

func (msg *Service) UnmarshalJSON(b []byte) error

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 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 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.

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.