Documentation ¶
Index ¶
- Constants
- Variables
- func DefaultConfigMetadata() metadata.MD
- func IsDefaultConfig(trailer metadata.MD) bool
- func RegisterAlertingNodeConfigurationServer(s grpc.ServiceRegistrar, srv AlertingNodeConfigurationServer)
- func RegisterNodeAlertingCapabilityServer(s grpc.ServiceRegistrar, srv NodeAlertingCapabilityServer)
- type AlertingCapabilityConfig
- func (*AlertingCapabilityConfig) Descriptor() ([]byte, []int)deprecated
- func (x *AlertingCapabilityConfig) GetConditions() []string
- func (x *AlertingCapabilityConfig) GetEnabled() bool
- func (x *AlertingCapabilityConfig) GetSpec() *AlertingCapabilitySpec
- func (*AlertingCapabilityConfig) ProtoMessage()
- func (x *AlertingCapabilityConfig) ProtoReflect() protoreflect.Message
- func (x *AlertingCapabilityConfig) Reset()
- func (x *AlertingCapabilityConfig) String() string
- type AlertingCapabilitySpec
- func (*AlertingCapabilitySpec) Descriptor() ([]byte, []int)deprecated
- func (x *AlertingCapabilitySpec) GetRuleDiscovery() *RuleDiscoverySpec
- func (*AlertingCapabilitySpec) ProtoMessage()
- func (x *AlertingCapabilitySpec) ProtoReflect() protoreflect.Message
- func (x *AlertingCapabilitySpec) Reset()
- func (x *AlertingCapabilitySpec) String() string
- func (a *AlertingCapabilitySpec) Validate() error
- type AlertingNodeConfigurationClient
- type AlertingNodeConfigurationServer
- type NodeAlertingCapabilityClient
- type NodeAlertingCapabilityServer
- type NodeConfigRequest
- func (*NodeConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeConfigRequest) GetNode() *v1.Reference
- func (x *NodeConfigRequest) GetSpec() *AlertingCapabilitySpec
- func (*NodeConfigRequest) ProtoMessage()
- func (x *NodeConfigRequest) ProtoReflect() protoreflect.Message
- func (x *NodeConfigRequest) Reset()
- func (x *NodeConfigRequest) String() string
- type RuleDiscoverySpec
- type SyncResponse
- func (*SyncResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncResponse) GetConfigStatus() v1.ConfigStatus
- func (x *SyncResponse) GetUpdatedConfig() *AlertingCapabilityConfig
- func (*SyncResponse) ProtoMessage()
- func (x *SyncResponse) ProtoReflect() protoreflect.Message
- func (x *SyncResponse) Reset()
- func (x *SyncResponse) String() string
- type UnimplementedAlertingNodeConfigurationServer
- func (UnimplementedAlertingNodeConfigurationServer) GetDefaultConfiguration(context.Context, *emptypb.Empty) (*AlertingCapabilitySpec, error)
- func (UnimplementedAlertingNodeConfigurationServer) GetNodeConfiguration(context.Context, *v1.Reference) (*AlertingCapabilitySpec, error)
- func (UnimplementedAlertingNodeConfigurationServer) SetDefaultConfiguration(context.Context, *AlertingCapabilitySpec) (*emptypb.Empty, error)
- func (UnimplementedAlertingNodeConfigurationServer) SetNodeConfiguration(context.Context, *NodeConfigRequest) (*emptypb.Empty, error)
- type UnimplementedNodeAlertingCapabilityServer
- type UnsafeAlertingNodeConfigurationServer
- type UnsafeNodeAlertingCapabilityServer
Constants ¶
const ( AlertingNodeConfiguration_GetDefaultConfiguration_FullMethodName = "/alerting.node.AlertingNodeConfiguration/GetDefaultConfiguration" AlertingNodeConfiguration_SetDefaultConfiguration_FullMethodName = "/alerting.node.AlertingNodeConfiguration/SetDefaultConfiguration" AlertingNodeConfiguration_GetNodeConfiguration_FullMethodName = "/alerting.node.AlertingNodeConfiguration/GetNodeConfiguration" AlertingNodeConfiguration_SetNodeConfiguration_FullMethodName = "/alerting.node.AlertingNodeConfiguration/SetNodeConfiguration" )
const (
NodeAlertingCapability_Sync_FullMethodName = "/alerting.node.NodeAlertingCapability/Sync"
)
Variables ¶
var AlertingNodeConfiguration_ServiceDesc = grpc.ServiceDesc{ ServiceName: "alerting.node.AlertingNodeConfiguration", HandlerType: (*AlertingNodeConfigurationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetDefaultConfiguration", Handler: _AlertingNodeConfiguration_GetDefaultConfiguration_Handler, }, { MethodName: "SetDefaultConfiguration", Handler: _AlertingNodeConfiguration_SetDefaultConfiguration_Handler, }, { MethodName: "GetNodeConfiguration", Handler: _AlertingNodeConfiguration_GetNodeConfiguration_Handler, }, { MethodName: "SetNodeConfiguration", Handler: _AlertingNodeConfiguration_SetNodeConfiguration_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/alerting/pkg/apis/node/node.proto", }
AlertingNodeConfiguration_ServiceDesc is the grpc.ServiceDesc for AlertingNodeConfiguration service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_github_com_rancher_opni_plugins_alerting_pkg_apis_node_node_proto protoreflect.FileDescriptor
var NodeAlertingCapability_ServiceDesc = grpc.ServiceDesc{ ServiceName: "alerting.node.NodeAlertingCapability", HandlerType: (*NodeAlertingCapabilityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Sync", Handler: _NodeAlertingCapability_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/alerting/pkg/apis/node/node.proto", }
NodeAlertingCapability_ServiceDesc is the grpc.ServiceDesc for NodeAlertingCapability service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DefaultConfigMetadata ¶
func IsDefaultConfig ¶
func RegisterAlertingNodeConfigurationServer ¶
func RegisterAlertingNodeConfigurationServer(s grpc.ServiceRegistrar, srv AlertingNodeConfigurationServer)
func RegisterNodeAlertingCapabilityServer ¶
func RegisterNodeAlertingCapabilityServer(s grpc.ServiceRegistrar, srv NodeAlertingCapabilityServer)
Types ¶
type AlertingCapabilityConfig ¶
type AlertingCapabilityConfig struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` Conditions []string `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"` Spec *AlertingCapabilitySpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*AlertingCapabilityConfig) Descriptor
deprecated
func (*AlertingCapabilityConfig) Descriptor() ([]byte, []int)
Deprecated: Use AlertingCapabilityConfig.ProtoReflect.Descriptor instead.
func (*AlertingCapabilityConfig) GetConditions ¶
func (x *AlertingCapabilityConfig) GetConditions() []string
func (*AlertingCapabilityConfig) GetEnabled ¶
func (x *AlertingCapabilityConfig) GetEnabled() bool
func (*AlertingCapabilityConfig) GetSpec ¶
func (x *AlertingCapabilityConfig) GetSpec() *AlertingCapabilitySpec
func (*AlertingCapabilityConfig) ProtoMessage ¶
func (*AlertingCapabilityConfig) ProtoMessage()
func (*AlertingCapabilityConfig) ProtoReflect ¶
func (x *AlertingCapabilityConfig) ProtoReflect() protoreflect.Message
func (*AlertingCapabilityConfig) Reset ¶
func (x *AlertingCapabilityConfig) Reset()
func (*AlertingCapabilityConfig) String ¶
func (x *AlertingCapabilityConfig) String() string
type AlertingCapabilitySpec ¶
type AlertingCapabilitySpec struct { RuleDiscovery *RuleDiscoverySpec `protobuf:"bytes,1,opt,name=ruleDiscovery,proto3" json:"ruleDiscovery,omitempty"` // contains filtered or unexported fields }
func (*AlertingCapabilitySpec) Descriptor
deprecated
func (*AlertingCapabilitySpec) Descriptor() ([]byte, []int)
Deprecated: Use AlertingCapabilitySpec.ProtoReflect.Descriptor instead.
func (*AlertingCapabilitySpec) GetRuleDiscovery ¶
func (x *AlertingCapabilitySpec) GetRuleDiscovery() *RuleDiscoverySpec
func (*AlertingCapabilitySpec) ProtoMessage ¶
func (*AlertingCapabilitySpec) ProtoMessage()
func (*AlertingCapabilitySpec) ProtoReflect ¶
func (x *AlertingCapabilitySpec) ProtoReflect() protoreflect.Message
func (*AlertingCapabilitySpec) Reset ¶
func (x *AlertingCapabilitySpec) Reset()
func (*AlertingCapabilitySpec) String ¶
func (x *AlertingCapabilitySpec) String() string
func (*AlertingCapabilitySpec) Validate ¶
func (a *AlertingCapabilitySpec) Validate() error
type AlertingNodeConfigurationClient ¶
type AlertingNodeConfigurationClient interface { GetDefaultConfiguration(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AlertingCapabilitySpec, error) SetDefaultConfiguration(ctx context.Context, in *AlertingCapabilitySpec, opts ...grpc.CallOption) (*emptypb.Empty, error) GetNodeConfiguration(ctx context.Context, in *v1.Reference, opts ...grpc.CallOption) (*AlertingCapabilitySpec, error) SetNodeConfiguration(ctx context.Context, in *NodeConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
AlertingNodeConfigurationClient is the client API for AlertingNodeConfiguration 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 NewAlertingNodeConfigurationClient ¶
func NewAlertingNodeConfigurationClient(cc grpc.ClientConnInterface) AlertingNodeConfigurationClient
type AlertingNodeConfigurationServer ¶
type AlertingNodeConfigurationServer interface { GetDefaultConfiguration(context.Context, *emptypb.Empty) (*AlertingCapabilitySpec, error) SetDefaultConfiguration(context.Context, *AlertingCapabilitySpec) (*emptypb.Empty, error) GetNodeConfiguration(context.Context, *v1.Reference) (*AlertingCapabilitySpec, error) SetNodeConfiguration(context.Context, *NodeConfigRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
AlertingNodeConfigurationServer is the server API for AlertingNodeConfiguration service. All implementations must embed UnimplementedAlertingNodeConfigurationServer for forward compatibility
type NodeAlertingCapabilityClient ¶
type NodeAlertingCapabilityClient interface {
Sync(ctx context.Context, in *AlertingCapabilityConfig, opts ...grpc.CallOption) (*SyncResponse, error)
}
NodeAlertingCapabilityClient is the client API for NodeAlertingCapability 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 NewNodeAlertingCapabilityClient ¶
func NewNodeAlertingCapabilityClient(cc grpc.ClientConnInterface) NodeAlertingCapabilityClient
type NodeAlertingCapabilityServer ¶
type NodeAlertingCapabilityServer interface { Sync(context.Context, *AlertingCapabilityConfig) (*SyncResponse, error) // contains filtered or unexported methods }
NodeAlertingCapabilityServer is the server API for NodeAlertingCapability service. All implementations must embed UnimplementedNodeAlertingCapabilityServer for forward compatibility
type NodeConfigRequest ¶
type NodeConfigRequest struct { Node *v1.Reference `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` Spec *AlertingCapabilitySpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*NodeConfigRequest) Descriptor
deprecated
func (*NodeConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodeConfigRequest.ProtoReflect.Descriptor instead.
func (*NodeConfigRequest) GetNode ¶
func (x *NodeConfigRequest) GetNode() *v1.Reference
func (*NodeConfigRequest) GetSpec ¶
func (x *NodeConfigRequest) GetSpec() *AlertingCapabilitySpec
func (*NodeConfigRequest) ProtoMessage ¶
func (*NodeConfigRequest) ProtoMessage()
func (*NodeConfigRequest) ProtoReflect ¶
func (x *NodeConfigRequest) ProtoReflect() protoreflect.Message
func (*NodeConfigRequest) Reset ¶
func (x *NodeConfigRequest) Reset()
func (*NodeConfigRequest) String ¶
func (x *NodeConfigRequest) String() string
type RuleDiscoverySpec ¶
type RuleDiscoverySpec struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // contains filtered or unexported fields }
func (*RuleDiscoverySpec) Descriptor
deprecated
func (*RuleDiscoverySpec) Descriptor() ([]byte, []int)
Deprecated: Use RuleDiscoverySpec.ProtoReflect.Descriptor instead.
func (*RuleDiscoverySpec) GetEnabled ¶
func (x *RuleDiscoverySpec) GetEnabled() bool
func (*RuleDiscoverySpec) ProtoMessage ¶
func (*RuleDiscoverySpec) ProtoMessage()
func (*RuleDiscoverySpec) ProtoReflect ¶
func (x *RuleDiscoverySpec) ProtoReflect() protoreflect.Message
func (*RuleDiscoverySpec) Reset ¶
func (x *RuleDiscoverySpec) Reset()
func (*RuleDiscoverySpec) String ¶
func (x *RuleDiscoverySpec) String() string
type SyncResponse ¶
type SyncResponse struct { ConfigStatus v1.ConfigStatus `protobuf:"varint,1,opt,name=configStatus,proto3,enum=core.ConfigStatus" json:"configStatus,omitempty"` UpdatedConfig *AlertingCapabilityConfig `protobuf:"bytes,2,opt,name=updatedConfig,proto3" json:"updatedConfig,omitempty"` // contains filtered or unexported fields }
func (*SyncResponse) Descriptor
deprecated
func (*SyncResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.
func (*SyncResponse) GetConfigStatus ¶
func (x *SyncResponse) GetConfigStatus() v1.ConfigStatus
func (*SyncResponse) GetUpdatedConfig ¶
func (x *SyncResponse) GetUpdatedConfig() *AlertingCapabilityConfig
func (*SyncResponse) ProtoMessage ¶
func (*SyncResponse) ProtoMessage()
func (*SyncResponse) ProtoReflect ¶
func (x *SyncResponse) ProtoReflect() protoreflect.Message
func (*SyncResponse) Reset ¶
func (x *SyncResponse) Reset()
func (*SyncResponse) String ¶
func (x *SyncResponse) String() string
type UnimplementedAlertingNodeConfigurationServer ¶
type UnimplementedAlertingNodeConfigurationServer struct { }
UnimplementedAlertingNodeConfigurationServer must be embedded to have forward compatible implementations.
func (UnimplementedAlertingNodeConfigurationServer) GetDefaultConfiguration ¶
func (UnimplementedAlertingNodeConfigurationServer) GetDefaultConfiguration(context.Context, *emptypb.Empty) (*AlertingCapabilitySpec, error)
func (UnimplementedAlertingNodeConfigurationServer) GetNodeConfiguration ¶
func (UnimplementedAlertingNodeConfigurationServer) GetNodeConfiguration(context.Context, *v1.Reference) (*AlertingCapabilitySpec, error)
func (UnimplementedAlertingNodeConfigurationServer) SetDefaultConfiguration ¶
func (UnimplementedAlertingNodeConfigurationServer) SetDefaultConfiguration(context.Context, *AlertingCapabilitySpec) (*emptypb.Empty, error)
func (UnimplementedAlertingNodeConfigurationServer) SetNodeConfiguration ¶
func (UnimplementedAlertingNodeConfigurationServer) SetNodeConfiguration(context.Context, *NodeConfigRequest) (*emptypb.Empty, error)
type UnimplementedNodeAlertingCapabilityServer ¶
type UnimplementedNodeAlertingCapabilityServer struct { }
UnimplementedNodeAlertingCapabilityServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeAlertingCapabilityServer) Sync ¶
func (UnimplementedNodeAlertingCapabilityServer) Sync(context.Context, *AlertingCapabilityConfig) (*SyncResponse, error)
type UnsafeAlertingNodeConfigurationServer ¶
type UnsafeAlertingNodeConfigurationServer interface {
// contains filtered or unexported methods
}
UnsafeAlertingNodeConfigurationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AlertingNodeConfigurationServer will result in compilation errors.
type UnsafeNodeAlertingCapabilityServer ¶
type UnsafeNodeAlertingCapabilityServer interface {
// contains filtered or unexported methods
}
UnsafeNodeAlertingCapabilityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeAlertingCapabilityServer will result in compilation errors.