Documentation
¶
Index ¶
- Variables
- func RegisterMonitoringServiceServer(s grpc.ServiceRegistrar, srv MonitoringServiceServer)
- type EntityState
- func (*EntityState) Descriptor() ([]byte, []int)deprecated
- func (x *EntityState) GetEntityRef() *EntityState_Ref
- func (x *EntityState) GetLoglines() []string
- func (x *EntityState) GetMessage() string
- func (x *EntityState) GetStatus() EntityState_Status
- func (x *EntityState) GetValue() []float32
- func (*EntityState) ProtoMessage()
- func (x *EntityState) ProtoReflect() protoreflect.Message
- func (x *EntityState) Reset()
- func (x *EntityState) String() string
- type EntityState_EntityType
- func (EntityState_EntityType) Descriptor() protoreflect.EnumDescriptor
- func (x EntityState_EntityType) Enum() *EntityState_EntityType
- func (EntityState_EntityType) EnumDescriptor() ([]byte, []int)deprecated
- func (x EntityState_EntityType) Number() protoreflect.EnumNumber
- func (x EntityState_EntityType) String() string
- func (EntityState_EntityType) Type() protoreflect.EnumType
- type EntityState_Ref
- func (*EntityState_Ref) Descriptor() ([]byte, []int)deprecated
- func (x *EntityState_Ref) GetEntityType() EntityState_EntityType
- func (x *EntityState_Ref) GetId() string
- func (x *EntityState_Ref) GetName() string
- func (x *EntityState_Ref) GetProjectId() string
- func (*EntityState_Ref) ProtoMessage()
- func (x *EntityState_Ref) ProtoReflect() protoreflect.Message
- func (x *EntityState_Ref) Reset()
- func (x *EntityState_Ref) String() string
- type EntityState_Status
- func (EntityState_Status) Descriptor() protoreflect.EnumDescriptor
- func (x EntityState_Status) Enum() *EntityState_Status
- func (EntityState_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x EntityState_Status) Number() protoreflect.EnumNumber
- func (x EntityState_Status) String() string
- func (EntityState_Status) Type() protoreflect.EnumType
- type GetEntityStatesRequest
- type GetEntityStatesResponse
- func (*GetEntityStatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityStatesResponse) GetStates() []*EntityState
- func (*GetEntityStatesResponse) ProtoMessage()
- func (x *GetEntityStatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetEntityStatesResponse) Reset()
- func (x *GetEntityStatesResponse) String() string
- type MonitoringServiceClient
- type MonitoringServiceServer
- type MonitoringService_GetEntityStatesClient
- type MonitoringService_GetEntityStatesServer
- type MonitoringService_UpdateEntityStatesClient
- type MonitoringService_UpdateEntityStatesServer
- type UnimplementedMonitoringServiceServer
- type UnsafeMonitoringServiceServer
- type UpdateEntityStatesRequest
- func (*UpdateEntityStatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEntityStatesRequest) GetStates() []*EntityState
- func (*UpdateEntityStatesRequest) ProtoMessage()
- func (x *UpdateEntityStatesRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateEntityStatesRequest) Reset()
- func (x *UpdateEntityStatesRequest) String() string
- type UpdateEntityStatesResponse
Constants ¶
This section is empty.
Variables ¶
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.
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.
var File_strmprivacy_api_monitoring_v1_monitoring_proto protoreflect.FileDescriptor
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) Descriptor() protoreflect.EnumDescriptor
func (EntityState_EntityType) Enum ¶ added in v2.62.0
func (x EntityState_EntityType) Enum() *EntityState_EntityType
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 (x EntityState_EntityType) Number() protoreflect.EnumNumber
func (EntityState_EntityType) String ¶ added in v2.62.0
func (x EntityState_EntityType) String() string
func (EntityState_EntityType) Type ¶ added in v2.62.0
func (EntityState_EntityType) Type() protoreflect.EnumType
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) Descriptor() protoreflect.EnumDescriptor
func (EntityState_Status) Enum ¶ added in v2.62.0
func (x EntityState_Status) Enum() *EntityState_Status
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 (x EntityState_Status) Number() protoreflect.EnumNumber
func (EntityState_Status) String ¶ added in v2.62.0
func (x EntityState_Status) String() string
func (EntityState_Status) Type ¶ added in v2.62.0
func (EntityState_Status) Type() protoreflect.EnumType
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.
func NewMonitoringServiceClient ¶
func NewMonitoringServiceClient(cc grpc.ClientConnInterface) MonitoringServiceClient
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) GetEntityStates ¶
func (UnimplementedMonitoringServiceServer) GetEntityStates(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) error
func (UnimplementedMonitoringServiceServer) UpdateEntityStates ¶ added in v2.62.0
func (UnimplementedMonitoringServiceServer) UpdateEntityStates(MonitoringService_UpdateEntityStatesServer) error
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 (x *UpdateEntityStatesRequest) ProtoReflect() protoreflect.Message
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 (x *UpdateEntityStatesResponse) ProtoReflect() protoreflect.Message
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