__

package
v0.0.0-...-112b7e3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_groups_proto protoreflect.FileDescriptor
View Source 
var RuleGroups_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rule_manager.groups.RuleGroups",
	HandlerType: (*RuleGroupsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Save",
			Handler:    _RuleGroups_Save_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _RuleGroups_Delete_Handler,
		},
		{
			MethodName: "List",
			Handler:    _RuleGroups_List_Handler,
		},
		{
			MethodName: "Fetch",
			Handler:    _RuleGroups_Fetch_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "groups.proto",
}

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

Functions

func RegisterRuleGroupsServer 

func RegisterRuleGroupsServer(s grpc.ServiceRegistrar, srv RuleGroupsServer)

Types

type DeleteRuleGroup 

type DeleteRuleGroup struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRuleGroup) Descriptor deprecated 

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

Deprecated: Use DeleteRuleGroup.ProtoReflect.Descriptor instead.

func (*DeleteRuleGroup) GetName 

func (x *DeleteRuleGroup) GetName() string

func (*DeleteRuleGroup) ProtoMessage 

func (*DeleteRuleGroup) ProtoMessage()

func (*DeleteRuleGroup) ProtoReflect 

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

func (*DeleteRuleGroup) Reset 

func (x *DeleteRuleGroup) Reset()

func (*DeleteRuleGroup) String 

func (x *DeleteRuleGroup) String() string

type FetchRuleGroup 

type FetchRuleGroup struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRuleGroup) Descriptor deprecated 

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

Deprecated: Use FetchRuleGroup.ProtoReflect.Descriptor instead.

func (*FetchRuleGroup) GetName 

func (x *FetchRuleGroup) GetName() string

func (*FetchRuleGroup) ProtoMessage 

func (*FetchRuleGroup) ProtoMessage()

func (*FetchRuleGroup) ProtoReflect 

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

func (*FetchRuleGroup) Reset 

func (x *FetchRuleGroup) Reset()

func (*FetchRuleGroup) String 

func (x *FetchRuleGroup) String() string

type FetchRuleGroupResult 

type FetchRuleGroupResult struct {
	RuleGroup *RecordingRuleGroup `protobuf:"bytes,1,opt,name=rule_group,json=ruleGroup,proto3" json:"rule_group,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRuleGroupResult) Descriptor deprecated 

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

Deprecated: Use FetchRuleGroupResult.ProtoReflect.Descriptor instead.

func (*FetchRuleGroupResult) GetRuleGroup 

func (x *FetchRuleGroupResult) GetRuleGroup() *RecordingRuleGroup

func (*FetchRuleGroupResult) ProtoMessage 

func (*FetchRuleGroupResult) ProtoMessage()

func (*FetchRuleGroupResult) ProtoReflect 

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

func (*FetchRuleGroupResult) Reset 

func (x *FetchRuleGroupResult) Reset()

func (*FetchRuleGroupResult) String 

func (x *FetchRuleGroupResult) String() string

type RecordingRule 

type RecordingRule struct {
	Record string            `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	Expr   string            `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RecordingRule) Descriptor deprecated 

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

Deprecated: Use RecordingRule.ProtoReflect.Descriptor instead.

func (*RecordingRule) GetExpr 

func (x *RecordingRule) GetExpr() string

func (*RecordingRule) GetLabels 

func (x *RecordingRule) GetLabels() map[string]string

func (*RecordingRule) GetRecord 

func (x *RecordingRule) GetRecord() string

func (*RecordingRule) ProtoMessage 

func (*RecordingRule) ProtoMessage()

func (*RecordingRule) ProtoReflect 

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

func (*RecordingRule) Reset 

func (x *RecordingRule) Reset()

func (*RecordingRule) String 

func (x *RecordingRule) String() string

type RecordingRuleGroup 

type RecordingRuleGroup struct {
	Name     string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Interval *uint32          `protobuf:"varint,2,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
	Limit    *uint64          `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Rules    []*RecordingRule `protobuf:"bytes,4,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordingRuleGroup) Descriptor deprecated 

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

Deprecated: Use RecordingRuleGroup.ProtoReflect.Descriptor instead.

func (*RecordingRuleGroup) GetInterval 

func (x *RecordingRuleGroup) GetInterval() uint32

func (*RecordingRuleGroup) GetLimit 

func (x *RecordingRuleGroup) GetLimit() uint64

func (*RecordingRuleGroup) GetName 

func (x *RecordingRuleGroup) GetName() string

func (*RecordingRuleGroup) GetRules 

func (x *RecordingRuleGroup) GetRules() []*RecordingRule

func (*RecordingRuleGroup) ProtoMessage 

func (*RecordingRuleGroup) ProtoMessage()

func (*RecordingRuleGroup) ProtoReflect 

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

func (*RecordingRuleGroup) Reset 

func (x *RecordingRuleGroup) Reset()

func (*RecordingRuleGroup) String 

func (x *RecordingRuleGroup) String() string

type RuleGroupListing 

type RuleGroupListing struct {
	RuleGroups []*RecordingRuleGroup `protobuf:"bytes,1,rep,name=rule_groups,json=ruleGroups,proto3" json:"rule_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleGroupListing) Descriptor deprecated 

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

Deprecated: Use RuleGroupListing.ProtoReflect.Descriptor instead.

func (*RuleGroupListing) GetRuleGroups 

func (x *RuleGroupListing) GetRuleGroups() []*RecordingRuleGroup

func (*RuleGroupListing) ProtoMessage 

func (*RuleGroupListing) ProtoMessage()

func (*RuleGroupListing) ProtoReflect 

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

func (*RuleGroupListing) Reset 

func (x *RuleGroupListing) Reset()

func (*RuleGroupListing) String 

func (x *RuleGroupListing) String() string

type RuleGroupsClient 

type RuleGroupsClient interface {
	Save(ctx context.Context, in *RecordingRuleGroup, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Delete(ctx context.Context, in *DeleteRuleGroup, opts ...grpc.CallOption) (*emptypb.Empty, error)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RuleGroupListing, error)
	Fetch(ctx context.Context, in *FetchRuleGroup, opts ...grpc.CallOption) (*FetchRuleGroupResult, error)
}

RuleGroupsClient is the client API for RuleGroups 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 NewRuleGroupsClient 

func NewRuleGroupsClient(cc grpc.ClientConnInterface) RuleGroupsClient

type RuleGroupsServer 

type RuleGroupsServer interface {
	Save(context.Context, *RecordingRuleGroup) (*emptypb.Empty, error)
	Delete(context.Context, *DeleteRuleGroup) (*emptypb.Empty, error)
	List(context.Context, *emptypb.Empty) (*RuleGroupListing, error)
	Fetch(context.Context, *FetchRuleGroup) (*FetchRuleGroupResult, error)
	// contains filtered or unexported methods
}

RuleGroupsServer is the server API for RuleGroups service. All implementations must embed UnimplementedRuleGroupsServer for forward compatibility

type UnimplementedRuleGroupsServer 

type UnimplementedRuleGroupsServer struct {
}

UnimplementedRuleGroupsServer must be embedded to have forward compatible implementations.

func (UnimplementedRuleGroupsServer) Delete 

func (UnimplementedRuleGroupsServer) Delete(context.Context, *DeleteRuleGroup) (*emptypb.Empty, error)

func (UnimplementedRuleGroupsServer) Fetch 

func (UnimplementedRuleGroupsServer) Fetch(context.Context, *FetchRuleGroup) (*FetchRuleGroupResult, error)

func (UnimplementedRuleGroupsServer) List 

func (UnimplementedRuleGroupsServer) List(context.Context, *emptypb.Empty) (*RuleGroupListing, error)

func (UnimplementedRuleGroupsServer) Save 

func (UnimplementedRuleGroupsServer) Save(context.Context, *RecordingRuleGroup) (*emptypb.Empty, error)

type UnsafeRuleGroupsServer 

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

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