alerting

package
v0.11.2-rc2 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MonitorManagement_CreateMonitor_FullMethodName = "/alerting.logging.MonitorManagement/CreateMonitor"
	MonitorManagement_GetMonitor_FullMethodName    = "/alerting.logging.MonitorManagement/GetMonitor"
	MonitorManagement_UpdateMonitor_FullMethodName = "/alerting.logging.MonitorManagement/UpdateMonitor"
	MonitorManagement_DeleteMonitor_FullMethodName = "/alerting.logging.MonitorManagement/DeleteMonitor"
)
View Source 
const (
	NotificationManagement_CreateNotification_FullMethodName = "/alerting.logging.NotificationManagement/CreateNotification"
	NotificationManagement_GetNotification_FullMethodName    = "/alerting.logging.NotificationManagement/GetNotification"
	NotificationManagement_ListNotifications_FullMethodName  = "/alerting.logging.NotificationManagement/ListNotifications"
	NotificationManagement_UpdateNotification_FullMethodName = "/alerting.logging.NotificationManagement/UpdateNotification"
	NotificationManagement_DeleteDestination_FullMethodName  = "/alerting.logging.NotificationManagement/DeleteDestination"
)
View Source 
const (
	AlertManagement_ListAlerts_FullMethodName       = "/alerting.logging.AlertManagement/ListAlerts"
	AlertManagement_AcknowledgeAlert_FullMethodName = "/alerting.logging.AlertManagement/AcknowledgeAlert"
)

Variables

View Source 
var AlertManagement_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alerting.logging.AlertManagement",
	HandlerType: (*AlertManagementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAlerts",
			Handler:    _AlertManagement_ListAlerts_Handler,
		},
		{
			MethodName: "AcknowledgeAlert",
			Handler:    _AlertManagement_AcknowledgeAlert_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/plugins/logging/apis/alerting/alerting.proto",
}

AlertManagement_ServiceDesc is the grpc.ServiceDesc for AlertManagement 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_logging_apis_alerting_alerting_proto protoreflect.FileDescriptor
View Source 
var MonitorManagement_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alerting.logging.MonitorManagement",
	HandlerType: (*MonitorManagementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateMonitor",
			Handler:    _MonitorManagement_CreateMonitor_Handler,
		},
		{
			MethodName: "GetMonitor",
			Handler:    _MonitorManagement_GetMonitor_Handler,
		},
		{
			MethodName: "UpdateMonitor",
			Handler:    _MonitorManagement_UpdateMonitor_Handler,
		},
		{
			MethodName: "DeleteMonitor",
			Handler:    _MonitorManagement_DeleteMonitor_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/plugins/logging/apis/alerting/alerting.proto",
}

MonitorManagement_ServiceDesc is the grpc.ServiceDesc for MonitorManagement 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 NotificationManagement_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alerting.logging.NotificationManagement",
	HandlerType: (*NotificationManagementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNotification",
			Handler:    _NotificationManagement_CreateNotification_Handler,
		},
		{
			MethodName: "GetNotification",
			Handler:    _NotificationManagement_GetNotification_Handler,
		},
		{
			MethodName: "ListNotifications",
			Handler:    _NotificationManagement_ListNotifications_Handler,
		},
		{
			MethodName: "UpdateNotification",
			Handler:    _NotificationManagement_UpdateNotification_Handler,
		},
		{
			MethodName: "DeleteDestination",
			Handler:    _NotificationManagement_DeleteDestination_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/plugins/logging/apis/alerting/alerting.proto",
}

NotificationManagement_ServiceDesc is the grpc.ServiceDesc for NotificationManagement service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAlertManagementServer 

func RegisterAlertManagementServer(s grpc.ServiceRegistrar, srv AlertManagementServer)

func RegisterMonitorManagementServer 

func RegisterMonitorManagementServer(s grpc.ServiceRegistrar, srv MonitorManagementServer)

func RegisterNotificationManagementServer 

func RegisterNotificationManagementServer(s grpc.ServiceRegistrar, srv NotificationManagementServer)

Types

type AcknowledgeAlertRequest 

type AcknowledgeAlertRequest struct {
	MonitorId string   `protobuf:"bytes,1,opt,name=monitorId,proto3" json:"monitorId,omitempty"`
	AlertIds  []string `protobuf:"bytes,2,rep,name=alertIds,proto3" json:"alertIds,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgeAlertRequest) Descriptor deprecated 

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

Deprecated: Use AcknowledgeAlertRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgeAlertRequest) GetAlertIds 

func (x *AcknowledgeAlertRequest) GetAlertIds() []string

func (*AcknowledgeAlertRequest) GetMonitorId 

func (x *AcknowledgeAlertRequest) GetMonitorId() string

func (*AcknowledgeAlertRequest) ProtoMessage 

func (*AcknowledgeAlertRequest) ProtoMessage()

func (*AcknowledgeAlertRequest) ProtoReflect 

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

func (*AcknowledgeAlertRequest) Reset 

func (x *AcknowledgeAlertRequest) Reset()

func (*AcknowledgeAlertRequest) String 

func (x *AcknowledgeAlertRequest) String() string

type AlertManagementClient 

type AlertManagementClient interface {
	ListAlerts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListAlertsResponse, error)
	AcknowledgeAlert(ctx context.Context, in *AcknowledgeAlertRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

AlertManagementClient is the client API for AlertManagement 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 NewAlertClient 

func NewAlertClient(ctx waitctx.PermissiveContext, opts ...AlertingClientOption) (AlertManagementClient, error)

func NewAlertManagementClient 

func NewAlertManagementClient(cc grpc.ClientConnInterface) AlertManagementClient

type AlertManagementServer 

type AlertManagementServer interface {
	ListAlerts(context.Context, *emptypb.Empty) (*ListAlertsResponse, error)
	AcknowledgeAlert(context.Context, *AcknowledgeAlertRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

AlertManagementServer is the server API for AlertManagement service. All implementations must embed UnimplementedAlertManagementServer for forward compatibility

type AlertingClientOption 

type AlertingClientOption func(*AlertingClientOptions)

func WithDialOptions 

func WithDialOptions(options ...grpc.DialOption) AlertingClientOption

func WithListenAddress 

func WithListenAddress(addr string) AlertingClientOption

type AlertingClientOptions 

type AlertingClientOptions struct {
	// contains filtered or unexported fields
}

type Channel 

type Channel struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	Spec      []byte `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Channel) Descriptor deprecated 

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

Deprecated: Use Channel.ProtoReflect.Descriptor instead.

func (*Channel) GetChannelId 

func (x *Channel) GetChannelId() string

func (*Channel) GetSpec 

func (x *Channel) GetSpec() []byte

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) ProtoReflect 

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

func (*Channel) Reset 

func (x *Channel) Reset()

func (*Channel) String 

func (x *Channel) String() string

type ChannelList 

type ChannelList struct {
	List []byte `protobuf:"bytes,1,opt,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelList) Descriptor deprecated 

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

Deprecated: Use ChannelList.ProtoReflect.Descriptor instead.

func (*ChannelList) GetList 

func (x *ChannelList) GetList() []byte

func (*ChannelList) ProtoMessage 

func (*ChannelList) ProtoMessage()

func (*ChannelList) ProtoReflect 

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

func (*ChannelList) Reset 

func (x *ChannelList) Reset()

func (*ChannelList) String 

func (x *ChannelList) String() string

type ListAlertsResponse 

type ListAlertsResponse struct {
	Alerts []byte `protobuf:"bytes,1,opt,name=alerts,proto3" json:"alerts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAlertsResponse) Descriptor deprecated 

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

Deprecated: Use ListAlertsResponse.ProtoReflect.Descriptor instead.

func (*ListAlertsResponse) GetAlerts 

func (x *ListAlertsResponse) GetAlerts() []byte

func (*ListAlertsResponse) ProtoMessage 

func (*ListAlertsResponse) ProtoMessage()

func (*ListAlertsResponse) ProtoReflect 

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

func (*ListAlertsResponse) Reset 

func (x *ListAlertsResponse) Reset()

func (*ListAlertsResponse) String 

func (x *ListAlertsResponse) String() string

type Monitor 

type Monitor struct {
	MonitorId   string `protobuf:"bytes,1,opt,name=monitorId,proto3" json:"monitorId,omitempty"`
	MonitorType string `protobuf:"bytes,2,opt,name=monitorType,proto3" json:"monitorType,omitempty"`
	Spec        []byte `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Monitor) Descriptor deprecated 

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

Deprecated: Use Monitor.ProtoReflect.Descriptor instead.

func (*Monitor) GetMonitorId 

func (x *Monitor) GetMonitorId() string

func (*Monitor) GetMonitorType 

func (x *Monitor) GetMonitorType() string

func (*Monitor) GetSpec 

func (x *Monitor) GetSpec() []byte

func (*Monitor) ProtoMessage 

func (*Monitor) ProtoMessage()

func (*Monitor) ProtoReflect 

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

func (*Monitor) Reset 

func (x *Monitor) Reset()

func (*Monitor) String 

func (x *Monitor) String() string

type MonitorManagementClient 

type MonitorManagementClient interface {
	CreateMonitor(ctx context.Context, in *Monitor, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetMonitor(ctx context.Context, in *v1.Reference, opts ...grpc.CallOption) (*Monitor, error)
	UpdateMonitor(ctx context.Context, in *Monitor, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteMonitor(ctx context.Context, in *v1.Reference, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

MonitorManagementClient is the client API for MonitorManagement 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 NewMonitorClient 

func NewMonitorClient(ctx waitctx.PermissiveContext, opts ...AlertingClientOption) (MonitorManagementClient, error)

func NewMonitorManagementClient 

func NewMonitorManagementClient(cc grpc.ClientConnInterface) MonitorManagementClient

type MonitorManagementServer 

type MonitorManagementServer interface {
	CreateMonitor(context.Context, *Monitor) (*emptypb.Empty, error)
	GetMonitor(context.Context, *v1.Reference) (*Monitor, error)
	UpdateMonitor(context.Context, *Monitor) (*emptypb.Empty, error)
	DeleteMonitor(context.Context, *v1.Reference) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

MonitorManagementServer is the server API for MonitorManagement service. All implementations must embed UnimplementedMonitorManagementServer for forward compatibility

type NotificationManagementClient 

type NotificationManagementClient interface {
	CreateNotification(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNotification(ctx context.Context, in *v1.Reference, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListNotifications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ChannelList, error)
	UpdateNotification(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteDestination(ctx context.Context, in *v1.Reference, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NotificationManagementClient is the client API for NotificationManagement 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 NewNotificationClient 

func NewNotificationClient(ctx waitctx.PermissiveContext, opts ...AlertingClientOption) (NotificationManagementClient, error)

func NewNotificationManagementClient 

func NewNotificationManagementClient(cc grpc.ClientConnInterface) NotificationManagementClient

type NotificationManagementServer 

type NotificationManagementServer interface {
	CreateNotification(context.Context, *Channel) (*emptypb.Empty, error)
	GetNotification(context.Context, *v1.Reference) (*emptypb.Empty, error)
	ListNotifications(context.Context, *emptypb.Empty) (*ChannelList, error)
	UpdateNotification(context.Context, *Channel) (*emptypb.Empty, error)
	DeleteDestination(context.Context, *v1.Reference) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

NotificationManagementServer is the server API for NotificationManagement service. All implementations must embed UnimplementedNotificationManagementServer for forward compatibility

type UnimplementedAlertManagementServer 

type UnimplementedAlertManagementServer struct {
}

UnimplementedAlertManagementServer must be embedded to have forward compatible implementations.

func (UnimplementedAlertManagementServer) AcknowledgeAlert 

func (UnimplementedAlertManagementServer) AcknowledgeAlert(context.Context, *AcknowledgeAlertRequest) (*emptypb.Empty, error)

func (UnimplementedAlertManagementServer) ListAlerts 

func (UnimplementedAlertManagementServer) ListAlerts(context.Context, *emptypb.Empty) (*ListAlertsResponse, error)

type UnimplementedMonitorManagementServer 

type UnimplementedMonitorManagementServer struct {
}

UnimplementedMonitorManagementServer must be embedded to have forward compatible implementations.

func (UnimplementedMonitorManagementServer) CreateMonitor 

func (UnimplementedMonitorManagementServer) CreateMonitor(context.Context, *Monitor) (*emptypb.Empty, error)

func (UnimplementedMonitorManagementServer) DeleteMonitor 

func (UnimplementedMonitorManagementServer) DeleteMonitor(context.Context, *v1.Reference) (*emptypb.Empty, error)

func (UnimplementedMonitorManagementServer) GetMonitor 

func (UnimplementedMonitorManagementServer) GetMonitor(context.Context, *v1.Reference) (*Monitor, error)

func (UnimplementedMonitorManagementServer) UpdateMonitor 

func (UnimplementedMonitorManagementServer) UpdateMonitor(context.Context, *Monitor) (*emptypb.Empty, error)

type UnimplementedNotificationManagementServer 

type UnimplementedNotificationManagementServer struct {
}

UnimplementedNotificationManagementServer must be embedded to have forward compatible implementations.

func (UnimplementedNotificationManagementServer) CreateNotification 

func (UnimplementedNotificationManagementServer) CreateNotification(context.Context, *Channel) (*emptypb.Empty, error)

func (UnimplementedNotificationManagementServer) DeleteDestination 

func (UnimplementedNotificationManagementServer) DeleteDestination(context.Context, *v1.Reference) (*emptypb.Empty, error)

func (UnimplementedNotificationManagementServer) GetNotification 

func (UnimplementedNotificationManagementServer) GetNotification(context.Context, *v1.Reference) (*emptypb.Empty, error)

func (UnimplementedNotificationManagementServer) ListNotifications 

func (UnimplementedNotificationManagementServer) ListNotifications(context.Context, *emptypb.Empty) (*ChannelList, error)

func (UnimplementedNotificationManagementServer) UpdateNotification 

func (UnimplementedNotificationManagementServer) UpdateNotification(context.Context, *Channel) (*emptypb.Empty, error)

type UnsafeAlertManagementServer 

type UnsafeAlertManagementServer interface {
	// contains filtered or unexported methods
}

UnsafeAlertManagementServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AlertManagementServer will result in compilation errors.

type UnsafeMonitorManagementServer 

type UnsafeMonitorManagementServer interface {
	// contains filtered or unexported methods
}

UnsafeMonitorManagementServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MonitorManagementServer will result in compilation errors.

type UnsafeNotificationManagementServer 

type UnsafeNotificationManagementServer interface {
	// contains filtered or unexported methods
}

UnsafeNotificationManagementServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationManagementServer 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.