v1

package
v0.5.633 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0: "EVENT_UPDATE",
		1: "EVENT_DELETE",
	}
	EventType_value = map[string]int32{
		"EVENT_UPDATE": 0,
		"EVENT_DELETE": 1,
	}
)

Enum value maps for EventType.

View Source 
var File_github_com_metaprov_modelaapi_services_watcherd_v1_watcherd_proto protoreflect.FileDescriptor
View Source 
var WatcherdService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.watcherd.v1.WatcherdService",
	HandlerType: (*WatcherdServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WatchDataset",
			Handler:    _WatcherdService_WatchDataset_Handler,
		},
		{
			MethodName: "WatchModel",
			Handler:    _WatcherdService_WatchModel_Handler,
		},
		{
			MethodName: "WatchAlert",
			Handler:    _WatcherdService_WatchAlert_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/watcherd/v1/watcherd.proto",
}

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

Functions

func RegisterWatcherdServiceServer 

func RegisterWatcherdServiceServer(s grpc.ServiceRegistrar, srv WatcherdServiceServer)

Types

type AlertEvent added in v0.5.614 

type AlertEvent struct {
	Event EventType        `` /* 130-byte string literal not displayed */
	Alert *v1alpha12.Alert `protobuf:"bytes,2,opt,name=alert,proto3" json:"alert,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertEvent) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use AlertEvent.ProtoReflect.Descriptor instead.

func (*AlertEvent) GetAlert added in v0.5.614 

func (x *AlertEvent) GetAlert() *v1alpha12.Alert

func (*AlertEvent) GetEvent added in v0.5.614 

func (x *AlertEvent) GetEvent() EventType

func (*AlertEvent) ProtoMessage added in v0.5.614 

func (*AlertEvent) ProtoMessage()

func (*AlertEvent) ProtoReflect added in v0.5.614 

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

func (*AlertEvent) Reset added in v0.5.614 

func (x *AlertEvent) Reset()

func (*AlertEvent) String added in v0.5.614 

func (x *AlertEvent) String() string

type DatasetEvent 

type DatasetEvent struct {
	Event   EventType         `` /* 130-byte string literal not displayed */
	Dataset *v1alpha1.Dataset `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetEvent) Descriptor deprecated 

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

Deprecated: Use DatasetEvent.ProtoReflect.Descriptor instead.

func (*DatasetEvent) GetDataset 

func (x *DatasetEvent) GetDataset() *v1alpha1.Dataset

func (*DatasetEvent) GetEvent 

func (x *DatasetEvent) GetEvent() EventType

func (*DatasetEvent) ProtoMessage 

func (*DatasetEvent) ProtoMessage()

func (*DatasetEvent) ProtoReflect 

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

func (*DatasetEvent) Reset 

func (x *DatasetEvent) Reset()

func (*DatasetEvent) String 

func (x *DatasetEvent) String() string

type EventType 

type EventType int32
const (
	EventType_EVENT_UPDATE EventType = 0
	EventType_EVENT_DELETE EventType = 1
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type ModelEvent added in v0.5.614 

type ModelEvent struct {
	Event EventType        `` /* 130-byte string literal not displayed */
	Model *v1alpha11.Model `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelEvent) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use ModelEvent.ProtoReflect.Descriptor instead.

func (*ModelEvent) GetEvent added in v0.5.614 

func (x *ModelEvent) GetEvent() EventType

func (*ModelEvent) GetModel added in v0.5.614 

func (x *ModelEvent) GetModel() *v1alpha11.Model

func (*ModelEvent) ProtoMessage added in v0.5.614 

func (*ModelEvent) ProtoMessage()

func (*ModelEvent) ProtoReflect added in v0.5.614 

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

func (*ModelEvent) Reset added in v0.5.614 

func (x *ModelEvent) Reset()

func (*ModelEvent) String added in v0.5.614 

func (x *ModelEvent) String() string

type UnimplementedWatcherdServiceServer 

type UnimplementedWatcherdServiceServer struct {
}

UnimplementedWatcherdServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWatcherdServiceServer) WatchAlert added in v0.5.614 

func (UnimplementedWatcherdServiceServer) WatchAlert(context.Context, *WatchAlertRequest) (*WatchAlertResponse, error)

func (UnimplementedWatcherdServiceServer) WatchDataset 

func (UnimplementedWatcherdServiceServer) WatchDataset(context.Context, *WatchDatasetRequest) (*WatchDatasetResponse, error)

func (UnimplementedWatcherdServiceServer) WatchModel added in v0.5.614 

func (UnimplementedWatcherdServiceServer) WatchModel(context.Context, *WatchModelRequest) (*WatchModelResponse, error)

type UnsafeWatcherdServiceServer 

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

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

type WatchAlertRequest added in v0.5.614 

type WatchAlertRequest struct {
	Generation uint64 `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Namespace  string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchAlertRequest) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use WatchAlertRequest.ProtoReflect.Descriptor instead.

func (*WatchAlertRequest) GetGeneration added in v0.5.614 

func (x *WatchAlertRequest) GetGeneration() uint64

func (*WatchAlertRequest) GetNamespace added in v0.5.614 

func (x *WatchAlertRequest) GetNamespace() string

func (*WatchAlertRequest) ProtoMessage added in v0.5.614 

func (*WatchAlertRequest) ProtoMessage()

func (*WatchAlertRequest) ProtoReflect added in v0.5.614 

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

func (*WatchAlertRequest) Reset added in v0.5.614 

func (x *WatchAlertRequest) Reset()

func (*WatchAlertRequest) String added in v0.5.614 

func (x *WatchAlertRequest) String() string

type WatchAlertResponse added in v0.5.614 

type WatchAlertResponse struct {
	Generation uint64        `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Events     []*AlertEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchAlertResponse) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use WatchAlertResponse.ProtoReflect.Descriptor instead.

func (*WatchAlertResponse) GetEvents added in v0.5.614 

func (x *WatchAlertResponse) GetEvents() []*AlertEvent

func (*WatchAlertResponse) GetGeneration added in v0.5.614 

func (x *WatchAlertResponse) GetGeneration() uint64

func (*WatchAlertResponse) ProtoMessage added in v0.5.614 

func (*WatchAlertResponse) ProtoMessage()

func (*WatchAlertResponse) ProtoReflect added in v0.5.614 

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

func (*WatchAlertResponse) Reset added in v0.5.614 

func (x *WatchAlertResponse) Reset()

func (*WatchAlertResponse) String added in v0.5.614 

func (x *WatchAlertResponse) String() string

type WatchDatasetRequest 

type WatchDatasetRequest struct {
	Generation uint64 `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Namespace  string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchDatasetRequest) Descriptor deprecated 

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

Deprecated: Use WatchDatasetRequest.ProtoReflect.Descriptor instead.

func (*WatchDatasetRequest) GetGeneration 

func (x *WatchDatasetRequest) GetGeneration() uint64

func (*WatchDatasetRequest) GetNamespace added in v0.5.612 

func (x *WatchDatasetRequest) GetNamespace() string

func (*WatchDatasetRequest) ProtoMessage 

func (*WatchDatasetRequest) ProtoMessage()

func (*WatchDatasetRequest) ProtoReflect 

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

func (*WatchDatasetRequest) Reset 

func (x *WatchDatasetRequest) Reset()

func (*WatchDatasetRequest) String 

func (x *WatchDatasetRequest) String() string

type WatchDatasetResponse 

type WatchDatasetResponse struct {
	Generation uint64          `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Events     []*DatasetEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchDatasetResponse) Descriptor deprecated 

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

Deprecated: Use WatchDatasetResponse.ProtoReflect.Descriptor instead.

func (*WatchDatasetResponse) GetEvents 

func (x *WatchDatasetResponse) GetEvents() []*DatasetEvent

func (*WatchDatasetResponse) GetGeneration 

func (x *WatchDatasetResponse) GetGeneration() uint64

func (*WatchDatasetResponse) ProtoMessage 

func (*WatchDatasetResponse) ProtoMessage()

func (*WatchDatasetResponse) ProtoReflect 

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

func (*WatchDatasetResponse) Reset 

func (x *WatchDatasetResponse) Reset()

func (*WatchDatasetResponse) String 

func (x *WatchDatasetResponse) String() string

type WatchModelRequest added in v0.5.614 

type WatchModelRequest struct {
	Generation uint64 `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Namespace  string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchModelRequest) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use WatchModelRequest.ProtoReflect.Descriptor instead.

func (*WatchModelRequest) GetGeneration added in v0.5.614 

func (x *WatchModelRequest) GetGeneration() uint64

func (*WatchModelRequest) GetNamespace added in v0.5.614 

func (x *WatchModelRequest) GetNamespace() string

func (*WatchModelRequest) ProtoMessage added in v0.5.614 

func (*WatchModelRequest) ProtoMessage()

func (*WatchModelRequest) ProtoReflect added in v0.5.614 

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

func (*WatchModelRequest) Reset added in v0.5.614 

func (x *WatchModelRequest) Reset()

func (*WatchModelRequest) String added in v0.5.614 

func (x *WatchModelRequest) String() string

type WatchModelResponse added in v0.5.614 

type WatchModelResponse struct {
	Generation uint64        `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Events     []*ModelEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchModelResponse) Descriptor deprecated added in v0.5.614 

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

Deprecated: Use WatchModelResponse.ProtoReflect.Descriptor instead.

func (*WatchModelResponse) GetEvents added in v0.5.614 

func (x *WatchModelResponse) GetEvents() []*ModelEvent

func (*WatchModelResponse) GetGeneration added in v0.5.614 

func (x *WatchModelResponse) GetGeneration() uint64

func (*WatchModelResponse) ProtoMessage added in v0.5.614 

func (*WatchModelResponse) ProtoMessage()

func (*WatchModelResponse) ProtoReflect added in v0.5.614 

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

func (*WatchModelResponse) Reset added in v0.5.614 

func (x *WatchModelResponse) Reset()

func (*WatchModelResponse) String added in v0.5.614 

func (x *WatchModelResponse) String() string

type WatcherdServiceClient 

type WatcherdServiceClient interface {
	WatchDataset(ctx context.Context, in *WatchDatasetRequest, opts ...grpc.CallOption) (*WatchDatasetResponse, error)
	WatchModel(ctx context.Context, in *WatchModelRequest, opts ...grpc.CallOption) (*WatchModelResponse, error)
	WatchAlert(ctx context.Context, in *WatchAlertRequest, opts ...grpc.CallOption) (*WatchAlertResponse, error)
}

WatcherdServiceClient is the client API for WatcherdService 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 NewWatcherdServiceClient 

func NewWatcherdServiceClient(cc grpc.ClientConnInterface) WatcherdServiceClient

type WatcherdServiceServer 

type WatcherdServiceServer interface {
	WatchDataset(context.Context, *WatchDatasetRequest) (*WatchDatasetResponse, error)
	WatchModel(context.Context, *WatchModelRequest) (*WatchModelResponse, error)
	WatchAlert(context.Context, *WatchAlertRequest) (*WatchAlertResponse, error)
	// contains filtered or unexported methods
}

WatcherdServiceServer is the server API for WatcherdService service. All implementations must embed UnimplementedWatcherdServiceServer for forward compatibility

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.