Documentation
¶
Index ¶
- Variables
- func RegisterMonitoringServiceServer(s grpc.ServiceRegistrar, srv MonitoringServiceServer)
- type GetEntityStatesRequest
- type GetEntityStatesResponse
- func (*GetEntityStatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityStatesResponse) GetStates() []*GetEntityStatesResponse_State
- func (*GetEntityStatesResponse) ProtoMessage()
- func (x *GetEntityStatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetEntityStatesResponse) Reset()
- func (x *GetEntityStatesResponse) String() string
- type GetEntityStatesResponse_Ref
- func (*GetEntityStatesResponse_Ref) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityStatesResponse_Ref) GetId() string
- func (x *GetEntityStatesResponse_Ref) GetName() string
- func (x *GetEntityStatesResponse_Ref) GetProjectId() string
- func (*GetEntityStatesResponse_Ref) ProtoMessage()
- func (x *GetEntityStatesResponse_Ref) ProtoReflect() protoreflect.Message
- func (x *GetEntityStatesResponse_Ref) Reset()
- func (x *GetEntityStatesResponse_Ref) String() string
- type GetEntityStatesResponse_State
- func (*GetEntityStatesResponse_State) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityStatesResponse_State) GetCustomerEntity() bool
- func (x *GetEntityStatesResponse_State) GetEntityRef() *GetEntityStatesResponse_Ref
- func (x *GetEntityStatesResponse_State) GetEntityType() string
- func (x *GetEntityStatesResponse_State) GetMessage() string
- func (x *GetEntityStatesResponse_State) GetState() string
- func (*GetEntityStatesResponse_State) ProtoMessage()
- func (x *GetEntityStatesResponse_State) ProtoReflect() protoreflect.Message
- func (x *GetEntityStatesResponse_State) Reset()
- func (x *GetEntityStatesResponse_State) String() string
- type MonitoringServiceClient
- type MonitoringServiceServer
- type MonitoringService_GetEntityStatesClient
- type MonitoringService_GetEntityStatesServer
- type UnimplementedMonitoringServiceServer
- type UnsafeMonitoringServiceServer
Constants ¶
This section is empty.
Variables ¶
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, }, }, 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 GetEntityStatesRequest ¶
type GetEntityStatesRequest struct {
// contains filtered or unexported fields
}
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 []*GetEntityStatesResponse_State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
// contains filtered or unexported fields
}
Initial call returns every entity state that's relevant to the caller.
Subsequent streaming gives deltas
func (*GetEntityStatesResponse) Descriptor
deprecated
func (*GetEntityStatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityStatesResponse.ProtoReflect.Descriptor instead.
func (*GetEntityStatesResponse) GetStates ¶
func (x *GetEntityStatesResponse) GetStates() []*GetEntityStatesResponse_State
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 GetEntityStatesResponse_Ref ¶
type GetEntityStatesResponse_Ref struct {
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*GetEntityStatesResponse_Ref) Descriptor
deprecated
func (*GetEntityStatesResponse_Ref) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityStatesResponse_Ref.ProtoReflect.Descriptor instead.
func (*GetEntityStatesResponse_Ref) GetId ¶
func (x *GetEntityStatesResponse_Ref) GetId() string
func (*GetEntityStatesResponse_Ref) GetName ¶
func (x *GetEntityStatesResponse_Ref) GetName() string
func (*GetEntityStatesResponse_Ref) GetProjectId ¶
func (x *GetEntityStatesResponse_Ref) GetProjectId() string
func (*GetEntityStatesResponse_Ref) ProtoMessage ¶
func (*GetEntityStatesResponse_Ref) ProtoMessage()
func (*GetEntityStatesResponse_Ref) ProtoReflect ¶
func (x *GetEntityStatesResponse_Ref) ProtoReflect() protoreflect.Message
func (*GetEntityStatesResponse_Ref) Reset ¶
func (x *GetEntityStatesResponse_Ref) Reset()
func (*GetEntityStatesResponse_Ref) String ¶
func (x *GetEntityStatesResponse_Ref) String() string
type GetEntityStatesResponse_State ¶
type GetEntityStatesResponse_State struct {
// sos, schema-registry, batch-job X, ...
EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
EntityRef *GetEntityStatesResponse_Ref `protobuf:"bytes,2,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"`
// healthy, broken, struggling, REMOVED
State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
// whether it's a STRM entity or a customer entity
CustomerEntity bool `protobuf:"varint,5,opt,name=customer_entity,json=customerEntity,proto3" json:"customer_entity,omitempty"`
// contains filtered or unexported fields
}
func (*GetEntityStatesResponse_State) Descriptor
deprecated
func (*GetEntityStatesResponse_State) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityStatesResponse_State.ProtoReflect.Descriptor instead.
func (*GetEntityStatesResponse_State) GetCustomerEntity ¶
func (x *GetEntityStatesResponse_State) GetCustomerEntity() bool
func (*GetEntityStatesResponse_State) GetEntityRef ¶
func (x *GetEntityStatesResponse_State) GetEntityRef() *GetEntityStatesResponse_Ref
func (*GetEntityStatesResponse_State) GetEntityType ¶
func (x *GetEntityStatesResponse_State) GetEntityType() string
func (*GetEntityStatesResponse_State) GetMessage ¶
func (x *GetEntityStatesResponse_State) GetMessage() string
func (*GetEntityStatesResponse_State) GetState ¶
func (x *GetEntityStatesResponse_State) GetState() string
func (*GetEntityStatesResponse_State) ProtoMessage ¶
func (*GetEntityStatesResponse_State) ProtoMessage()
func (*GetEntityStatesResponse_State) ProtoReflect ¶
func (x *GetEntityStatesResponse_State) ProtoReflect() protoreflect.Message
func (*GetEntityStatesResponse_State) Reset ¶
func (x *GetEntityStatesResponse_State) Reset()
func (*GetEntityStatesResponse_State) String ¶
func (x *GetEntityStatesResponse_State) String() string
type MonitoringServiceClient ¶
type MonitoringServiceClient interface {
GetEntityStates(ctx context.Context, in *GetEntityStatesRequest, opts ...grpc.CallOption) (MonitoringService_GetEntityStatesClient, 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 {
GetEntityStates(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) 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 UnimplementedMonitoringServiceServer ¶
type UnimplementedMonitoringServiceServer struct {
}
UnimplementedMonitoringServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMonitoringServiceServer) GetEntityStates ¶
func (UnimplementedMonitoringServiceServer) GetEntityStates(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) 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.