node

package
v0.12.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	NodeAlertingCapability_Sync_FullMethodName = "/alerting.node.NodeAlertingCapability/Sync"
)

Variables

View Source 
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)

View Source 
var File_github_com_rancher_opni_plugins_alerting_pkg_apis_node_node_proto protoreflect.FileDescriptor
View Source 
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 DefaultConfigMetadata() metadata.MD

func IsDefaultConfig 

func IsDefaultConfig(trailer metadata.MD) bool

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.

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.