proto

package
v0.0.0-...-ec93226 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2024 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CRDKind_name = map[int32]string{
		0: "UPFDeployment",
		1: "SMFDeployment",
		2: "AMFDeployment",
	}
	CRDKind_value = map[string]int32{
		"UPFDeployment": 0,
		"SMFDeployment": 1,
		"AMFDeployment": 2,
	}
)

Enum value maps for CRDKind.

View Source 
var (
	APIGroup_name = map[int32]string{
		0: "NFDeployNephioOrg",
	}
	APIGroup_value = map[string]int32{
		"NFDeployNephioOrg": 0,
	}
)

Enum value maps for APIGroup.

View Source 
var (
	Version_name = map[int32]string{
		0: "v1alpha1",
	}
	Version_value = map[string]int32{
		"v1alpha1": 0,
	}
)

Enum value maps for Version.

View Source 
var (
	EventType_name = map[int32]string{
		0: "Added",
		1: "Modified",
		2: "Deleted",
		3: "List",
	}
	EventType_value = map[string]int32{
		"Added":    0,
		"Modified": 1,
		"Deleted":  2,
		"List":     3,
	}
)

Enum value maps for EventType.

View Source 
var (
	ResponseType_name = map[int32]string{
		0: "OK",
		1: "RESET",
	}
	ResponseType_value = map[string]int32{
		"OK":    0,
		"RESET": 1,
	}
)

Enum value maps for ResponseType.

View Source 
var File_protos_edgewatcher_proto protoreflect.FileDescriptor
View Source 
var WatcherService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "watcher.WatcherService",
	HandlerType: (*WatcherServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportEvent",
			Handler:    _WatcherService_ReportEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/edgewatcher.proto",
}

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

Functions

func RegisterWatcherServiceServer 

func RegisterWatcherServiceServer(s grpc.ServiceRegistrar, srv WatcherServiceServer)

Types

type APIGroup 

type APIGroup int32
const (
	APIGroup_NFDeployNephioOrg APIGroup = 0
)

func (APIGroup) Descriptor 

func (APIGroup) Descriptor() protoreflect.EnumDescriptor

func (APIGroup) Enum 

func (x APIGroup) Enum() *APIGroup

func (APIGroup) EnumDescriptor deprecated 

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

Deprecated: Use APIGroup.Descriptor instead.

func (APIGroup) Number 

func (x APIGroup) Number() protoreflect.EnumNumber

func (APIGroup) String 

func (x APIGroup) String() string

func (APIGroup) Type 

func (APIGroup) Type() protoreflect.EnumType

type CRDKind 

type CRDKind int32
const (
	CRDKind_UPFDeployment CRDKind = 0
	CRDKind_SMFDeployment CRDKind = 1
	CRDKind_AMFDeployment CRDKind = 2
)

func (CRDKind) Descriptor 

func (CRDKind) Descriptor() protoreflect.EnumDescriptor

func (CRDKind) Enum 

func (x CRDKind) Enum() *CRDKind

func (CRDKind) EnumDescriptor deprecated 

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

Deprecated: Use CRDKind.Descriptor instead.

func (CRDKind) Number 

func (x CRDKind) Number() protoreflect.EnumNumber

func (CRDKind) String 

func (x CRDKind) String() string

func (CRDKind) Type 

func (CRDKind) Type() protoreflect.EnumType

type EventRequest 

type EventRequest struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	// event_timestamp is used to identify and discard stale events
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_timestamp,json=eventTimestamp,proto3,oneof" json:"event_timestamp,omitempty"`
	// object is serialized k8s resource from an edgecluster
	Object []byte `protobuf:"bytes,3,opt,name=object,proto3,oneof" json:"object,omitempty"`
	// contains filtered or unexported fields
}

EventRequest contains metadata and serialized CR from an edge cluster

func (*EventRequest) Descriptor deprecated 

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

Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.

func (*EventRequest) GetEventTimestamp 

func (x *EventRequest) GetEventTimestamp() *timestamppb.Timestamp

func (*EventRequest) GetMetadata 

func (x *EventRequest) GetMetadata() *Metadata

func (*EventRequest) GetObject 

func (x *EventRequest) GetObject() []byte

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) ProtoReflect 

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

func (*EventRequest) Reset 

func (x *EventRequest) Reset()

func (*EventRequest) String 

func (x *EventRequest) String() string

type EventResponse 

type EventResponse struct {
	Response *ResponseType `protobuf:"varint,1,opt,name=Response,proto3,enum=watcher.ResponseType,oneof" json:"Response,omitempty"`
	// contains filtered or unexported fields
}

func (*EventResponse) Descriptor deprecated 

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

Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.

func (*EventResponse) GetResponse 

func (x *EventResponse) GetResponse() ResponseType

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) ProtoReflect 

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

func (*EventResponse) Reset 

func (x *EventResponse) Reset()

func (*EventResponse) String 

func (x *EventResponse) String() string

type EventType 

type EventType int32
const (
	EventType_Added    EventType = 0
	EventType_Modified EventType = 1
	EventType_Deleted  EventType = 2
	EventType_List     EventType = 3
)

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 Metadata 

type Metadata struct {
	Type    *EventType       `protobuf:"varint,1,opt,name=Type,proto3,enum=watcher.EventType,oneof" json:"Type,omitempty"`
	Request *RequestMetadata `protobuf:"bytes,2,opt,name=request,proto3,oneof" json:"request,omitempty"`
	// cluster_name is canonical name from one platform api
	ClusterName  *string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3,oneof" json:"cluster_name,omitempty"`
	NfdeployName *string `protobuf:"bytes,4,opt,name=nfdeploy_name,json=nfdeployName,proto3,oneof" json:"nfdeploy_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetClusterName 

func (x *Metadata) GetClusterName() string

func (*Metadata) GetNfdeployName 

func (x *Metadata) GetNfdeployName() string

func (*Metadata) GetRequest 

func (x *Metadata) GetRequest() *RequestMetadata

func (*Metadata) GetType 

func (x *Metadata) GetType() EventType

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type RequestMetadata 

type RequestMetadata struct {
	Namespace *string   `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Kind      *CRDKind  `protobuf:"varint,2,opt,name=kind,proto3,enum=watcher.CRDKind,oneof" json:"kind,omitempty"`
	Group     *APIGroup `protobuf:"varint,3,opt,name=group,proto3,enum=watcher.APIGroup,oneof" json:"group,omitempty"`
	Version   *Version  `protobuf:"varint,4,opt,name=version,proto3,enum=watcher.Version,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

RequestMetadata contains watcheragent's request parameters which were used to to configure watcheragent

func (*RequestMetadata) Descriptor deprecated 

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

Deprecated: Use RequestMetadata.ProtoReflect.Descriptor instead.

func (*RequestMetadata) GetGroup 

func (x *RequestMetadata) GetGroup() APIGroup

func (*RequestMetadata) GetKind 

func (x *RequestMetadata) GetKind() CRDKind

func (*RequestMetadata) GetNamespace 

func (x *RequestMetadata) GetNamespace() string

func (*RequestMetadata) GetVersion 

func (x *RequestMetadata) GetVersion() Version

func (*RequestMetadata) ProtoMessage 

func (*RequestMetadata) ProtoMessage()

func (*RequestMetadata) ProtoReflect 

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

func (*RequestMetadata) Reset 

func (x *RequestMetadata) Reset()

func (*RequestMetadata) String 

func (x *RequestMetadata) String() string

type ResponseType 

type ResponseType int32
const (
	// OK response signals that the Event was accepted by the edgewatcher
	ResponseType_OK ResponseType = 0
	// RESET response signals that the watcher-agent should reset the watch,
	// which entails the List call followed by watch calls.
	// This mechanism can be used by clients in case the original list
	// gets lost due to a crash.
	ResponseType_RESET ResponseType = 1
)

func (ResponseType) Descriptor 

func (ResponseType) Descriptor() protoreflect.EnumDescriptor

func (ResponseType) Enum 

func (x ResponseType) Enum() *ResponseType

func (ResponseType) EnumDescriptor deprecated 

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

Deprecated: Use ResponseType.Descriptor instead.

func (ResponseType) Number 

func (x ResponseType) Number() protoreflect.EnumNumber

func (ResponseType) String 

func (x ResponseType) String() string

func (ResponseType) Type 

func (ResponseType) Type() protoreflect.EnumType

type UnimplementedWatcherServiceServer 

type UnimplementedWatcherServiceServer struct {
}

UnimplementedWatcherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWatcherServiceServer) ReportEvent 

func (UnimplementedWatcherServiceServer) ReportEvent(context.Context, *EventRequest) (*EventResponse, error)

type UnsafeWatcherServiceServer 

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

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

type Version 

type Version int32
const (
	Version_v1alpha1 Version = 0
)

func (Version) Descriptor 

func (Version) Descriptor() protoreflect.EnumDescriptor

func (Version) Enum 

func (x Version) Enum() *Version

func (Version) EnumDescriptor deprecated 

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

Deprecated: Use Version.Descriptor instead.

func (Version) Number 

func (x Version) Number() protoreflect.EnumNumber

func (Version) String 

func (x Version) String() string

func (Version) Type 

func (Version) Type() protoreflect.EnumType

type WatcherServiceClient 

type WatcherServiceClient interface {
	ReportEvent(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*EventResponse, error)
}

WatcherServiceClient is the client API for WatcherService 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 NewWatcherServiceClient 

func NewWatcherServiceClient(cc grpc.ClientConnInterface) WatcherServiceClient

type WatcherServiceServer 

type WatcherServiceServer interface {
	ReportEvent(context.Context, *EventRequest) (*EventResponse, error)
	// contains filtered or unexported methods
}

WatcherServiceServer is the server API for WatcherService service. All implementations must embed UnimplementedWatcherServiceServer 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.