monitoring

package
v2.87.1 Latest Latest
Warning

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

Go to latest
Published: Jun 5, 2023 License: Apache-2.0 Imports: 11 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",
		6: "RESTARTING",
	}
	EntityState_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"HEALTHY":            1,
		"REMOVED":            2,
		"PENDING":            3,
		"TERMINATING":        4,
		"UNHEALTHY":          5,
		"RESTARTING":         6,
	}
)

Enum value maps for EntityState_Status.

View Source
var (
	EntityState_EntityType_name = map[int32]string{
		0: "ENTITY_TYPE_UNSPECIFIED",
		1: "BATCH_JOB",
		2: "STREAM",
		3: "BATCH_EXPORTER",
		4: "DATA_CONNECTOR",
		5: "KAFKA_EXPORTER",
	}
	EntityState_EntityType_value = map[string]int32{
		"ENTITY_TYPE_UNSPECIFIED": 0,
		"BATCH_JOB":               1,
		"STREAM":                  2,
		"BATCH_EXPORTER":          3,
		"DATA_CONNECTOR":          4,
		"KAFKA_EXPORTER":          5,
	}
)

Enum value maps for EntityState_EntityType.

View Source
var (
	EntityState_ResourceType_name = map[int32]string{
		0:   "RESOURCE_TYPE_UNSPECIFIED",
		100: "BATCH_JOB_JOB",
		101: "BATCH_JOB_SECRET",
		102: "BATCH_JOB_CONFIG_MAP",
		120: "STREAM_TOPIC",
		121: "STREAM_ENCRYPTION_KEYS_TOPIC",
		122: "STREAM_DECRYPTER_DEPLOYMENT",
		123: "STREAM_DECRYPTER_CONFIG_MAP",
		140: "BATCH_EXPORTER_DEPLOYMENT",
		141: "BATCH_EXPORTER_SECRET",
		150: "DATA_CONNECTOR_SECRET",
		160: "KAFKA_EXPORTER_DEPLOYMENT",
	}
	EntityState_ResourceType_value = map[string]int32{
		"RESOURCE_TYPE_UNSPECIFIED":    0,
		"BATCH_JOB_JOB":                100,
		"BATCH_JOB_SECRET":             101,
		"BATCH_JOB_CONFIG_MAP":         102,
		"STREAM_TOPIC":                 120,
		"STREAM_ENCRYPTION_KEYS_TOPIC": 121,
		"STREAM_DECRYPTER_DEPLOYMENT":  122,
		"STREAM_DECRYPTER_CONFIG_MAP":  123,
		"BATCH_EXPORTER_DEPLOYMENT":    140,
		"BATCH_EXPORTER_SECRET":        141,
		"DATA_CONNECTOR_SECRET":        150,
		"KAFKA_EXPORTER_DEPLOYMENT":    160,
	}
)

Enum value maps for EntityState_ResourceType.

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{
		{
			MethodName: "GetLatestEntityStates",
			Handler:    _MonitoringService_GetLatestEntityStates_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEntityState",
			Handler:       _MonitoringService_GetEntityState_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 {
	StateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=state_time,json=stateTime,proto3" json:"state_time,omitempty"`
	Ref       *EntityState_Ref       `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// also used to indicate that the entity is being removed.
	Status EntityState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=strmprivacy.api.monitoring.v1.EntityState_Status" json:"status,omitempty"`
	// generic status message, often empty, meant for resources that are not necessarily Kubernetes pods
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// logging in case the entity is unhealthy
	Logs         []string                 `protobuf:"bytes,5,rep,name=logs,proto3" json:"logs,omitempty"`
	ResourceType EntityState_ResourceType `` /* 158-byte string literal not displayed */
	// 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) GetLogs added in v2.66.0

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

func (*EntityState) GetMessage added in v2.62.0

func (x *EntityState) GetMessage() string

func (*EntityState) GetRef added in v2.66.0

func (x *EntityState) GetRef() *EntityState_Ref

func (*EntityState) GetResourceType added in v2.66.0

func (x *EntityState) GetResourceType() EntityState_ResourceType

func (*EntityState) GetStateTime added in v2.66.0

func (x *EntityState) GetStateTime() *timestamppb.Timestamp

func (*EntityState) GetStatus added in v2.62.0

func (x *EntityState) GetStatus() EntityState_Status

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
	EntityState_BATCH_JOB               EntityState_EntityType = 1
	EntityState_STREAM                  EntityState_EntityType = 2
	EntityState_BATCH_EXPORTER          EntityState_EntityType = 3
	EntityState_DATA_CONNECTOR          EntityState_EntityType = 4
	EntityState_KAFKA_EXPORTER          EntityState_EntityType = 5
)

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 {
	Type      EntityState_EntityType `protobuf:"varint,1,opt,name=type,proto3,enum=strmprivacy.api.monitoring.v1.EntityState_EntityType" json:"type,omitempty"`
	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"`
	// 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) 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) GetType added in v2.66.0

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_ResourceType added in v2.66.0

type EntityState_ResourceType int32
const (
	EntityState_RESOURCE_TYPE_UNSPECIFIED    EntityState_ResourceType = 0
	EntityState_BATCH_JOB_JOB                EntityState_ResourceType = 100
	EntityState_BATCH_JOB_SECRET             EntityState_ResourceType = 101
	EntityState_BATCH_JOB_CONFIG_MAP         EntityState_ResourceType = 102
	EntityState_STREAM_TOPIC                 EntityState_ResourceType = 120
	EntityState_STREAM_ENCRYPTION_KEYS_TOPIC EntityState_ResourceType = 121
	EntityState_STREAM_DECRYPTER_DEPLOYMENT  EntityState_ResourceType = 122
	EntityState_STREAM_DECRYPTER_CONFIG_MAP  EntityState_ResourceType = 123
	EntityState_BATCH_EXPORTER_DEPLOYMENT    EntityState_ResourceType = 140
	EntityState_BATCH_EXPORTER_SECRET        EntityState_ResourceType = 141
	EntityState_DATA_CONNECTOR_SECRET        EntityState_ResourceType = 150
	EntityState_KAFKA_EXPORTER_DEPLOYMENT    EntityState_ResourceType = 160
)

func (EntityState_ResourceType) Descriptor added in v2.66.0

func (EntityState_ResourceType) Enum added in v2.66.0

func (EntityState_ResourceType) EnumDescriptor deprecated added in v2.66.0

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

Deprecated: Use EntityState_ResourceType.Descriptor instead.

func (EntityState_ResourceType) Number added in v2.66.0

func (EntityState_ResourceType) String added in v2.66.0

func (x EntityState_ResourceType) String() string

func (EntityState_ResourceType) Type added in v2.66.0

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
	EntityState_REMOVED            EntityState_Status = 2
	EntityState_PENDING            EntityState_Status = 3
	EntityState_TERMINATING        EntityState_Status = 4
	EntityState_UNHEALTHY          EntityState_Status = 5
	EntityState_RESTARTING         EntityState_Status = 6
)

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 GetEntityStateRequest added in v2.66.0

type GetEntityStateRequest struct {

	// Filter based on a specific entity ref (or partially based on the ref's fields)
	Ref *EntityState_Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Filter based on a specific entity status
	Status EntityState_Status `protobuf:"varint,2,opt,name=status,proto3,enum=strmprivacy.api.monitoring.v1.EntityState_Status" json:"status,omitempty"`
	// Specify the fields that need to be part of the response. If left empty, all details will be returned.
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-masks-in-projections
	ProjectionMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=projection_mask,json=projectionMask,proto3" json:"projection_mask,omitempty"`
	// contains filtered or unexported fields
}

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

Subsequent streaming gives changes only.

func (*GetEntityStateRequest) Descriptor deprecated added in v2.66.0

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

Deprecated: Use GetEntityStateRequest.ProtoReflect.Descriptor instead.

func (*GetEntityStateRequest) GetProjectionMask added in v2.66.0

func (x *GetEntityStateRequest) GetProjectionMask() *fieldmaskpb.FieldMask

func (*GetEntityStateRequest) GetRef added in v2.66.0

func (*GetEntityStateRequest) GetStatus added in v2.66.0

func (*GetEntityStateRequest) ProtoMessage added in v2.66.0

func (*GetEntityStateRequest) ProtoMessage()

func (*GetEntityStateRequest) ProtoReflect added in v2.66.0

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

func (*GetEntityStateRequest) Reset added in v2.66.0

func (x *GetEntityStateRequest) Reset()

func (*GetEntityStateRequest) String added in v2.66.0

func (x *GetEntityStateRequest) String() string

type GetEntityStateResponse added in v2.66.0

type GetEntityStateResponse struct {
	State *EntityState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntityStateResponse) Descriptor deprecated added in v2.66.0

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

Deprecated: Use GetEntityStateResponse.ProtoReflect.Descriptor instead.

func (*GetEntityStateResponse) GetState added in v2.66.0

func (x *GetEntityStateResponse) GetState() *EntityState

func (*GetEntityStateResponse) ProtoMessage added in v2.66.0

func (*GetEntityStateResponse) ProtoMessage()

func (*GetEntityStateResponse) ProtoReflect added in v2.66.0

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

func (*GetEntityStateResponse) Reset added in v2.66.0

func (x *GetEntityStateResponse) Reset()

func (*GetEntityStateResponse) String added in v2.66.0

func (x *GetEntityStateResponse) String() string

type GetLatestEntityStatesRequest added in v2.68.0

type GetLatestEntityStatesRequest struct {

	// Filter based on a specific entity ref (or partially based on the ref's fields)
	Ref *EntityState_Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Filter based on a specific entity status
	Status EntityState_Status `protobuf:"varint,2,opt,name=status,proto3,enum=strmprivacy.api.monitoring.v1.EntityState_Status" json:"status,omitempty"`
	// Specify the fields that need to be part of the response. If left empty, all details will be returned.
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-masks-in-projections
	ProjectionMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=projection_mask,json=projectionMask,proto3" json:"projection_mask,omitempty"`
	// contains filtered or unexported fields
}

* Returns the latest entity state that's relevant to the caller.

func (*GetLatestEntityStatesRequest) Descriptor deprecated added in v2.68.0

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

Deprecated: Use GetLatestEntityStatesRequest.ProtoReflect.Descriptor instead.

func (*GetLatestEntityStatesRequest) GetProjectionMask added in v2.68.0

func (x *GetLatestEntityStatesRequest) GetProjectionMask() *fieldmaskpb.FieldMask

func (*GetLatestEntityStatesRequest) GetRef added in v2.68.0

func (*GetLatestEntityStatesRequest) GetStatus added in v2.68.0

func (*GetLatestEntityStatesRequest) ProtoMessage added in v2.68.0

func (*GetLatestEntityStatesRequest) ProtoMessage()

func (*GetLatestEntityStatesRequest) ProtoReflect added in v2.68.0

func (*GetLatestEntityStatesRequest) Reset added in v2.68.0

func (x *GetLatestEntityStatesRequest) Reset()

func (*GetLatestEntityStatesRequest) String added in v2.68.0

type GetLatestEntityStatesResponse added in v2.68.0

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

func (*GetLatestEntityStatesResponse) Descriptor deprecated added in v2.68.0

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

Deprecated: Use GetLatestEntityStatesResponse.ProtoReflect.Descriptor instead.

func (*GetLatestEntityStatesResponse) GetState added in v2.68.0

func (x *GetLatestEntityStatesResponse) GetState() []*EntityState

func (*GetLatestEntityStatesResponse) ProtoMessage added in v2.68.0

func (*GetLatestEntityStatesResponse) ProtoMessage()

func (*GetLatestEntityStatesResponse) ProtoReflect added in v2.68.0

func (*GetLatestEntityStatesResponse) Reset added in v2.68.0

func (x *GetLatestEntityStatesResponse) Reset()

func (*GetLatestEntityStatesResponse) String added in v2.68.0

type MonitoringServiceClient

type MonitoringServiceClient interface {
	// will be called by end users from the cli or console, to retrieve entity states
	// and indicate them to users.
	GetEntityState(ctx context.Context, in *GetEntityStateRequest, opts ...grpc.CallOption) (MonitoringService_GetEntityStateClient, error)
	// can be called via the CLI and the Console, to get the latest entity state for all entities included
	// in this request
	GetLatestEntityStates(ctx context.Context, in *GetLatestEntityStatesRequest, opts ...grpc.CallOption) (*GetLatestEntityStatesResponse, 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 by end users from the cli or console, to retrieve entity states
	// and indicate them to users.
	GetEntityState(*GetEntityStateRequest, MonitoringService_GetEntityStateServer) error
	// can be called via the CLI and the Console, to get the latest entity state for all entities included
	// in this request
	GetLatestEntityStates(context.Context, *GetLatestEntityStatesRequest) (*GetLatestEntityStatesResponse, 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
}

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

type MonitoringService_GetEntityStateClient added in v2.66.0

type MonitoringService_GetEntityStateClient interface {
	Recv() (*GetEntityStateResponse, error)
	grpc.ClientStream
}

type MonitoringService_GetEntityStateServer added in v2.66.0

type MonitoringService_GetEntityStateServer interface {
	Send(*GetEntityStateResponse) 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 should be embedded to have forward compatible implementations.

func (UnimplementedMonitoringServiceServer) GetEntityState added in v2.66.0

func (UnimplementedMonitoringServiceServer) GetLatestEntityStates added in v2.68.0

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
}

Only when changes occur to resources, an entity state is sent (-- 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