monitoring

package
v2.64.0 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	EntityState_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "HEALTHY",
		2: "REMOVED",
		3: "PENDING",
		4: "TERMINATING",
		5: "UNHEALTHY",
	}
	EntityState_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"HEALTHY":            1,
		"REMOVED":            2,
		"PENDING":            3,
		"TERMINATING":        4,
		"UNHEALTHY":          5,
	}
)

Enum value maps for EntityState_Status.

View Source
var (
	EntityState_EntityType_name = map[int32]string{
		0:    "ENTITY_TYPE_UNSPECIFIED",
		1:    "SOS",
		2:    "SCHEMA_REGISTRY",
		3:    "OMA",
		1000: "BATCH_JOB",
		1001: "SOURCE_STREAM",
		1002: "DERIVED_STREAM",
	}
	EntityState_EntityType_value = map[string]int32{
		"ENTITY_TYPE_UNSPECIFIED": 0,
		"SOS":                     1,
		"SCHEMA_REGISTRY":         2,
		"OMA":                     3,
		"BATCH_JOB":               1000,
		"SOURCE_STREAM":           1001,
		"DERIVED_STREAM":          1002,
	}
)

Enum value maps for EntityState_EntityType.

View Source
var File_strmprivacy_api_monitoring_v1_monitoring_proto protoreflect.FileDescriptor
View Source
var MonitoringService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.monitoring.v1.MonitoringService",
	HandlerType: (*MonitoringServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEntityStates",
			Handler:       _MonitoringService_GetEntityStates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UpdateEntityStates",
			Handler:       _MonitoringService_UpdateEntityStates_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "strmprivacy/api/monitoring/v1/monitoring.proto",
}

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

Functions

func RegisterMonitoringServiceServer

func RegisterMonitoringServiceServer(s grpc.ServiceRegistrar, srv MonitoringServiceServer)

Types

type EntityState added in v2.62.0

type EntityState struct {
	EntityRef *EntityState_Ref `protobuf:"bytes,1,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"`
	// also used to indicate that the entity is being removed.
	Status EntityState_Status `protobuf:"varint,2,opt,name=status,proto3,enum=strmprivacy.api.monitoring.v1.EntityState_Status" json:"status,omitempty"`
	// generic status message, often empty
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// generic floating point values like cpu, latency, ...
	Value []float32 `protobuf:"fixed32,4,rep,packed,name=value,proto3" json:"value,omitempty"`
	// logging in case the entity is unhealthy
	Loglines []string `protobuf:"bytes,5,rep,name=loglines,proto3" json:"loglines,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityState) Descriptor deprecated added in v2.62.0

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

Deprecated: Use EntityState.ProtoReflect.Descriptor instead.

func (*EntityState) GetEntityRef added in v2.62.0

func (x *EntityState) GetEntityRef() *EntityState_Ref

func (*EntityState) GetLoglines added in v2.62.0

func (x *EntityState) GetLoglines() []string

func (*EntityState) GetMessage added in v2.62.0

func (x *EntityState) GetMessage() string

func (*EntityState) GetStatus added in v2.62.0

func (x *EntityState) GetStatus() EntityState_Status

func (*EntityState) GetValue added in v2.62.0

func (x *EntityState) GetValue() []float32

func (*EntityState) ProtoMessage added in v2.62.0

func (*EntityState) ProtoMessage()

func (*EntityState) ProtoReflect added in v2.62.0

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

func (*EntityState) Reset added in v2.62.0

func (x *EntityState) Reset()

func (*EntityState) String added in v2.62.0

func (x *EntityState) String() string

type EntityState_EntityType added in v2.62.0

type EntityState_EntityType int32

what kind of entity category or instance are we dealing with

const (
	EntityState_ENTITY_TYPE_UNSPECIFIED EntityState_EntityType = 0
	// start with the STRM entities
	EntityState_SOS             EntityState_EntityType = 1
	EntityState_SCHEMA_REGISTRY EntityState_EntityType = 2
	EntityState_OMA             EntityState_EntityType = 3
	// and have a separate range for the customer entities...
	EntityState_BATCH_JOB      EntityState_EntityType = 1000
	EntityState_SOURCE_STREAM  EntityState_EntityType = 1001
	EntityState_DERIVED_STREAM EntityState_EntityType = 1002
)

func (EntityState_EntityType) Descriptor added in v2.62.0

func (EntityState_EntityType) Enum added in v2.62.0

func (EntityState_EntityType) EnumDescriptor deprecated added in v2.62.0

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

Deprecated: Use EntityState_EntityType.Descriptor instead.

func (EntityState_EntityType) Number added in v2.62.0

func (EntityState_EntityType) String added in v2.62.0

func (x EntityState_EntityType) String() string

func (EntityState_EntityType) Type added in v2.62.0

type EntityState_Ref added in v2.62.0

type EntityState_Ref struct {
	EntityType EntityState_EntityType `` /* 150-byte string literal not displayed */
	ProjectId  string                 `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name       string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Id         string                 `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

a unique reference to the entity

func (*EntityState_Ref) Descriptor deprecated added in v2.62.0

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

Deprecated: Use EntityState_Ref.ProtoReflect.Descriptor instead.

func (*EntityState_Ref) GetEntityType added in v2.62.0

func (x *EntityState_Ref) GetEntityType() EntityState_EntityType

func (*EntityState_Ref) GetId added in v2.62.0

func (x *EntityState_Ref) GetId() string

func (*EntityState_Ref) GetName added in v2.62.0

func (x *EntityState_Ref) GetName() string

func (*EntityState_Ref) GetProjectId added in v2.62.0

func (x *EntityState_Ref) GetProjectId() string

func (*EntityState_Ref) ProtoMessage added in v2.62.0

func (*EntityState_Ref) ProtoMessage()

func (*EntityState_Ref) ProtoReflect added in v2.62.0

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

func (*EntityState_Ref) Reset added in v2.62.0

func (x *EntityState_Ref) Reset()

func (*EntityState_Ref) String added in v2.62.0

func (x *EntityState_Ref) String() string

type EntityState_Status added in v2.62.0

type EntityState_Status int32

(-- api-linter: core::0216::synonyms=disabled

const (
	EntityState_STATUS_UNSPECIFIED EntityState_Status = 0
	EntityState_HEALTHY            EntityState_Status = 1
	// removed from the entity states
	EntityState_REMOVED     EntityState_Status = 2
	EntityState_PENDING     EntityState_Status = 3
	EntityState_TERMINATING EntityState_Status = 4
	EntityState_UNHEALTHY   EntityState_Status = 5
)

func (EntityState_Status) Descriptor added in v2.62.0

func (EntityState_Status) Enum added in v2.62.0

func (EntityState_Status) EnumDescriptor deprecated added in v2.62.0

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

Deprecated: Use EntityState_Status.Descriptor instead.

func (EntityState_Status) Number added in v2.62.0

func (EntityState_Status) String added in v2.62.0

func (x EntityState_Status) String() string

func (EntityState_Status) Type added in v2.62.0

type GetEntityStatesRequest

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

Initial call returns every entity state that's relevant to the caller.

Subsequent streaming gives changes only.

func (*GetEntityStatesRequest) Descriptor deprecated

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

Deprecated: Use GetEntityStatesRequest.ProtoReflect.Descriptor instead.

func (*GetEntityStatesRequest) ProtoMessage

func (*GetEntityStatesRequest) ProtoMessage()

func (*GetEntityStatesRequest) ProtoReflect

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

func (*GetEntityStatesRequest) Reset

func (x *GetEntityStatesRequest) Reset()

func (*GetEntityStatesRequest) String

func (x *GetEntityStatesRequest) String() string

type GetEntityStatesResponse

type GetEntityStatesResponse struct {
	States []*EntityState `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntityStatesResponse) Descriptor deprecated

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

Deprecated: Use GetEntityStatesResponse.ProtoReflect.Descriptor instead.

func (*GetEntityStatesResponse) GetStates

func (x *GetEntityStatesResponse) GetStates() []*EntityState

func (*GetEntityStatesResponse) ProtoMessage

func (*GetEntityStatesResponse) ProtoMessage()

func (*GetEntityStatesResponse) ProtoReflect

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

func (*GetEntityStatesResponse) Reset

func (x *GetEntityStatesResponse) Reset()

func (*GetEntityStatesResponse) String

func (x *GetEntityStatesResponse) String() string

type MonitoringServiceClient

type MonitoringServiceClient interface {
	//
	// will be called from clients such as cli or console, to retrieve entity states
	// and indicate them to users.
	GetEntityStates(ctx context.Context, in *GetEntityStatesRequest, opts ...grpc.CallOption) (MonitoringService_GetEntityStatesClient, error)
	//
	// will be called from entity agents so that they can send the entity states
	// of items they're responsible for to the monitoring service.
	UpdateEntityStates(ctx context.Context, opts ...grpc.CallOption) (MonitoringService_UpdateEntityStatesClient, error)
}

MonitoringServiceClient is the client API for MonitoringService 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.

type MonitoringServiceServer

type MonitoringServiceServer interface {
	//
	// will be called from clients such as cli or console, to retrieve entity states
	// and indicate them to users.
	GetEntityStates(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) error
	//
	// will be called from entity agents so that they can send the entity states
	// of items they're responsible for to the monitoring service.
	UpdateEntityStates(MonitoringService_UpdateEntityStatesServer) error
	// contains filtered or unexported methods
}

MonitoringServiceServer is the server API for MonitoringService service. All implementations must embed UnimplementedMonitoringServiceServer for forward compatibility

type MonitoringService_GetEntityStatesClient

type MonitoringService_GetEntityStatesClient interface {
	Recv() (*GetEntityStatesResponse, error)
	grpc.ClientStream
}

type MonitoringService_GetEntityStatesServer

type MonitoringService_GetEntityStatesServer interface {
	Send(*GetEntityStatesResponse) error
	grpc.ServerStream
}

type MonitoringService_UpdateEntityStatesClient added in v2.62.0

type MonitoringService_UpdateEntityStatesClient interface {
	Send(*UpdateEntityStatesRequest) error
	CloseAndRecv() (*UpdateEntityStatesResponse, error)
	grpc.ClientStream
}

type MonitoringService_UpdateEntityStatesServer added in v2.62.0

type MonitoringService_UpdateEntityStatesServer interface {
	SendAndClose(*UpdateEntityStatesResponse) error
	Recv() (*UpdateEntityStatesRequest, error)
	grpc.ServerStream
}

type UnimplementedMonitoringServiceServer

type UnimplementedMonitoringServiceServer struct {
}

UnimplementedMonitoringServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMonitoringServiceServer) UpdateEntityStates added in v2.62.0

type UnsafeMonitoringServiceServer

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

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

type UpdateEntityStatesRequest added in v2.62.0

type UpdateEntityStatesRequest struct {
	States []*EntityState `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

Initial call sets every entity state that's controlled by the caller

Subsequent stream sends only changes. (-- api-linter: core::0134::request-mask-required=disabled

func (*UpdateEntityStatesRequest) Descriptor deprecated added in v2.62.0

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

Deprecated: Use UpdateEntityStatesRequest.ProtoReflect.Descriptor instead.

func (*UpdateEntityStatesRequest) GetStates added in v2.62.0

func (x *UpdateEntityStatesRequest) GetStates() []*EntityState

func (*UpdateEntityStatesRequest) ProtoMessage added in v2.62.0

func (*UpdateEntityStatesRequest) ProtoMessage()

func (*UpdateEntityStatesRequest) ProtoReflect added in v2.62.0

func (*UpdateEntityStatesRequest) Reset added in v2.62.0

func (x *UpdateEntityStatesRequest) Reset()

func (*UpdateEntityStatesRequest) String added in v2.62.0

func (x *UpdateEntityStatesRequest) String() string

type UpdateEntityStatesResponse added in v2.62.0

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

func (*UpdateEntityStatesResponse) Descriptor deprecated added in v2.62.0

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

Deprecated: Use UpdateEntityStatesResponse.ProtoReflect.Descriptor instead.

func (*UpdateEntityStatesResponse) ProtoMessage added in v2.62.0

func (*UpdateEntityStatesResponse) ProtoMessage()

func (*UpdateEntityStatesResponse) ProtoReflect added in v2.62.0

func (*UpdateEntityStatesResponse) Reset added in v2.62.0

func (x *UpdateEntityStatesResponse) Reset()

func (*UpdateEntityStatesResponse) String added in v2.62.0

func (x *UpdateEntityStatesResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL