fluxninjav1

package
v2.23.2 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Overview

Package fluxninjav1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ControllerInfoService_GetControllerInfo_FullMethodName = "/aperture.fluxninja.v1.ControllerInfoService/GetControllerInfo"
)
View Source 
const (
	FluxNinjaService_Report_FullMethodName = "/aperture.fluxninja.v1.FluxNinjaService/Report"
)

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
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)

View Source 
var File_aperture_fluxninja_v1_heartbeat_proto protoreflect.FileDescriptor
View Source 
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) 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) MarshalToSizedBufferVT added in v2.7.0 

func (m *ControllerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControllerInfo) MarshalToVT added in v2.7.0 

func (m *ControllerInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ControllerInfo) MarshalVT added in v2.7.0 

func (m *ControllerInfo) MarshalVT() (dAtA []byte, err error)

func (*ControllerInfo) ProtoMessage 

func (*ControllerInfo) ProtoMessage()

func (*ControllerInfo) ProtoReflect 

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

func (*ControllerInfo) Reset 

func (x *ControllerInfo) Reset()

func (*ControllerInfo) SizeVT added in v2.7.0 

func (m *ControllerInfo) SizeVT() (n int)

func (*ControllerInfo) String 

func (x *ControllerInfo) String() string

func (*ControllerInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ControllerInfo) UnmarshalVT added in v2.7.0 

func (m *ControllerInfo) UnmarshalVT(dAtA []byte) error

func (*ControllerInfo) Validate 

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 

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 

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 

func (m ControllerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ControllerInfoMultiError) Error 

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 

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 

func (e ControllerInfoValidationError) Cause() error

Cause function returns cause value.

func (ControllerInfoValidationError) Error 

func (e ControllerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ControllerInfoValidationError) ErrorName 

func (e ControllerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ControllerInfoValidationError) Field 

func (e ControllerInfoValidationError) Field() string

Field function returns field value.

func (ControllerInfoValidationError) Key 

func (e ControllerInfoValidationError) Key() bool

Key function returns key value.

func (ControllerInfoValidationError) Reason 

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) 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) MarshalToSizedBufferVT added in v2.7.0 

func (m *OverlappingService) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OverlappingService) MarshalToVT added in v2.7.0 

func (m *OverlappingService) MarshalToVT(dAtA []byte) (int, error)

func (*OverlappingService) MarshalVT added in v2.7.0 

func (m *OverlappingService) MarshalVT() (dAtA []byte, err error)

func (*OverlappingService) ProtoMessage 

func (*OverlappingService) ProtoMessage()

func (*OverlappingService) ProtoReflect 

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

func (*OverlappingService) Reset 

func (x *OverlappingService) Reset()

func (*OverlappingService) SizeVT added in v2.7.0 

func (m *OverlappingService) SizeVT() (n int)

func (*OverlappingService) String 

func (x *OverlappingService) String() string

func (*OverlappingService) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*OverlappingService) UnmarshalVT added in v2.7.0 

func (m *OverlappingService) UnmarshalVT(dAtA []byte) error

func (*OverlappingService) Validate 

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 

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 

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 

func (m OverlappingServiceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OverlappingServiceMultiError) Error 

func (m OverlappingServiceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OverlappingServiceValidationError 

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 

func (e OverlappingServiceValidationError) Cause() error

Cause function returns cause value.

func (OverlappingServiceValidationError) Error 

func (e OverlappingServiceValidationError) Error() string

Error satisfies the builtin error interface

func (OverlappingServiceValidationError) ErrorName 

func (e OverlappingServiceValidationError) ErrorName() string

ErrorName returns error name.

func (OverlappingServiceValidationError) Field 

func (e OverlappingServiceValidationError) Field() string

Field function returns field value.

func (OverlappingServiceValidationError) Key 

func (e OverlappingServiceValidationError) Key() bool

Key function returns key value.

func (OverlappingServiceValidationError) Reason 

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) 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) MarshalToSizedBufferVT added in v2.7.0 

func (m *ReportRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReportRequest) MarshalToVT added in v2.7.0 

func (m *ReportRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReportRequest) MarshalVT added in v2.7.0 

func (m *ReportRequest) MarshalVT() (dAtA []byte, err error)

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) ProtoReflect 

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

func (*ReportRequest) Reset 

func (x *ReportRequest) Reset()

func (*ReportRequest) SizeVT added in v2.7.0 

func (m *ReportRequest) SizeVT() (n int)

func (*ReportRequest) String 

func (x *ReportRequest) String() string

func (*ReportRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ReportRequest) UnmarshalVT added in v2.7.0 

func (m *ReportRequest) UnmarshalVT(dAtA []byte) error

func (*ReportRequest) Validate 

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 

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 

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 

func (m ReportRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReportRequestMultiError) Error 

func (m ReportRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReportRequestValidationError 

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 

func (e ReportRequestValidationError) Cause() error

Cause function returns cause value.

func (ReportRequestValidationError) Error 

func (e ReportRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ReportRequestValidationError) ErrorName 

func (e ReportRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ReportRequestValidationError) Field 

func (e ReportRequestValidationError) Field() string

Field function returns field value.

func (ReportRequestValidationError) Key 

func (e ReportRequestValidationError) Key() bool

Key function returns key value.

func (ReportRequestValidationError) Reason 

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) 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) MarshalToSizedBufferVT added in v2.7.0 

func (m *ReportResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReportResponse) MarshalToVT added in v2.7.0 

func (m *ReportResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReportResponse) MarshalVT added in v2.7.0 

func (m *ReportResponse) MarshalVT() (dAtA []byte, err error)

func (*ReportResponse) ProtoMessage 

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) ProtoReflect 

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

func (*ReportResponse) Reset 

func (x *ReportResponse) Reset()

func (*ReportResponse) SizeVT added in v2.7.0 

func (m *ReportResponse) SizeVT() (n int)

func (*ReportResponse) String 

func (x *ReportResponse) String() string

func (*ReportResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ReportResponse) UnmarshalVT added in v2.7.0 

func (m *ReportResponse) UnmarshalVT(dAtA []byte) error

func (*ReportResponse) Validate 

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 

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 

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 

func (m ReportResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReportResponseMultiError) Error 

func (m ReportResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReportResponseValidationError 

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 

func (e ReportResponseValidationError) Cause() error

Cause function returns cause value.

func (ReportResponseValidationError) Error 

func (e ReportResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ReportResponseValidationError) ErrorName 

func (e ReportResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ReportResponseValidationError) Field 

func (e ReportResponseValidationError) Field() string

Field function returns field value.

func (ReportResponseValidationError) Key 

func (e ReportResponseValidationError) Key() bool

Key function returns key value.

func (ReportResponseValidationError) Reason 

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) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetEntitiesCount 

func (x *Service) GetEntitiesCount() int32

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*Service) MarshalToSizedBufferVT added in v2.7.0 

func (m *Service) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Service) MarshalToVT added in v2.7.0 

func (m *Service) MarshalToVT(dAtA []byte) (int, error)

func (*Service) MarshalVT added in v2.7.0 

func (m *Service) MarshalVT() (dAtA []byte, err error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) SizeVT added in v2.7.0 

func (m *Service) SizeVT() (n int)

func (*Service) String 

func (x *Service) String() string

func (*Service) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*Service) UnmarshalVT added in v2.7.0 

func (m *Service) UnmarshalVT(dAtA []byte) error

func (*Service) Validate 

func (m *Service) Validate() error

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 

func (m *Service) ValidateAll() error

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 

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 

func (m ServiceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ServiceMultiError) Error 

func (m ServiceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ServiceValidationError 

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 

func (e ServiceValidationError) Cause() error

Cause function returns cause value.

func (ServiceValidationError) Error 

func (e ServiceValidationError) Error() string

Error satisfies the builtin error interface

func (ServiceValidationError) ErrorName 

func (e ServiceValidationError) ErrorName() string

ErrorName returns error name.

func (ServiceValidationError) Field 

func (e ServiceValidationError) Field() string

Field function returns field value.

func (ServiceValidationError) Key 

func (e ServiceValidationError) Key() bool

Key function returns key value.

func (ServiceValidationError) Reason 

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) 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) MarshalToSizedBufferVT added in v2.7.0 

func (m *ServicesList) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ServicesList) MarshalToVT added in v2.7.0 

func (m *ServicesList) MarshalToVT(dAtA []byte) (int, error)

func (*ServicesList) MarshalVT added in v2.7.0 

func (m *ServicesList) MarshalVT() (dAtA []byte, err error)

func (*ServicesList) ProtoMessage 

func (*ServicesList) ProtoMessage()

func (*ServicesList) ProtoReflect 

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

func (*ServicesList) Reset 

func (x *ServicesList) Reset()

func (*ServicesList) SizeVT added in v2.7.0 

func (m *ServicesList) SizeVT() (n int)

func (*ServicesList) String 

func (x *ServicesList) String() string

func (*ServicesList) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ServicesList) UnmarshalVT added in v2.7.0 

func (m *ServicesList) UnmarshalVT(dAtA []byte) error

func (*ServicesList) Validate 

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 

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 

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 

func (m ServicesListMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ServicesListMultiError) Error 

func (m ServicesListMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ServicesListValidationError 

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 

func (e ServicesListValidationError) Cause() error

Cause function returns cause value.

func (ServicesListValidationError) Error 

func (e ServicesListValidationError) Error() string

Error satisfies the builtin error interface

func (ServicesListValidationError) ErrorName 

func (e ServicesListValidationError) ErrorName() string

ErrorName returns error name.

func (ServicesListValidationError) Field 

func (e ServicesListValidationError) Field() string

Field function returns field value.

func (ServicesListValidationError) Key 

func (e ServicesListValidationError) Key() bool

Key function returns key value.

func (ServicesListValidationError) Reason 

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.

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.