monitoring

package

Go to main page

Versions in this module

v2

v2.87.1

Jun 5, 2023

v2.87.0

Jun 5, 2023

v2.86.0

Jun 1, 2023

v2.85.0

May 30, 2023

v2.84.0

May 10, 2023

v2.83.0

May 5, 2023

v2.82.0

Apr 28, 2023

v2.81.1

Apr 18, 2023

v2.81.0

Apr 12, 2023

v2.80.0

Mar 2, 2023

v2.79.0

Feb 15, 2023

v2.78.0

Feb 13, 2023

v2.77.1

Feb 8, 2023

v2.77.0

Feb 8, 2023

v2.76.0

Feb 6, 2023

v2.75.0

Jan 16, 2023

Changes in this version

type EntityState_ResourceType

+ const EntityState_STREAM_DECRYPTER_CONFIG_MAP

v2.74.0

Jan 16, 2023

v2.73.2

Jan 12, 2023

v2.73.1

Jan 11, 2023

v2.73.0

Jan 11, 2023

v2.72.0

Jan 10, 2023

Changes in this version

type EntityState_EntityType

+ const EntityState_DATA_CONNECTOR

+ const EntityState_KAFKA_EXPORTER

type EntityState_ResourceType

+ const EntityState_BATCH_JOB_CONFIG_MAP

+ const EntityState_BATCH_JOB_JOB

+ const EntityState_DATA_CONNECTOR_SECRET

+ const EntityState_KAFKA_EXPORTER_DEPLOYMENT

v2.71.0

Jan 9, 2023

v2.70.1

Jan 6, 2023

v2.70.0

Jan 4, 2023

v2.69.2

Dec 27, 2022

v2.69.1

Dec 27, 2022

v2.69.0

Dec 21, 2022

v2.68.0

Dec 20, 2022

Changes in this version

+ type GetLatestEntityStatesRequest struct

+ ProjectionMask *fieldmaskpb.FieldMask

+ Ref *EntityState_Ref

+ Status EntityState_Status

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

+ func (*GetLatestEntityStatesRequest) ProtoMessage()

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

+ func (x *GetLatestEntityStatesRequest) GetRef() *EntityState_Ref

+ func (x *GetLatestEntityStatesRequest) GetStatus() EntityState_Status

+ func (x *GetLatestEntityStatesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestEntityStatesRequest) Reset()

+ func (x *GetLatestEntityStatesRequest) String() string

+ type GetLatestEntityStatesResponse struct

+ State []*EntityState

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

+ func (*GetLatestEntityStatesResponse) ProtoMessage()

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

+ func (x *GetLatestEntityStatesResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestEntityStatesResponse) Reset()

+ func (x *GetLatestEntityStatesResponse) String() string

type MonitoringServiceClient

+ GetLatestEntityStates func(ctx context.Context, in *GetLatestEntityStatesRequest, opts ...grpc.CallOption) (*GetLatestEntityStatesResponse, error)

type MonitoringServiceServer

+ GetLatestEntityStates func(context.Context, *GetLatestEntityStatesRequest) (*GetLatestEntityStatesResponse, error)

type UnimplementedMonitoringServiceServer

+ func (UnimplementedMonitoringServiceServer) GetLatestEntityStates(context.Context, *GetLatestEntityStatesRequest) (*GetLatestEntityStatesResponse, error)

v2.67.0

Dec 14, 2022

v2.66.0

Dec 14, 2022

Changes in this version

+ var EntityState_ResourceType_name = map[int32]string

+ var EntityState_ResourceType_value = map[string]int32

type EntityState

+ Logs []string

+ Ref *EntityState_Ref

+ ResourceType EntityState_ResourceType

+ StateTime *timestamppb.Timestamp

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

+ func (x *EntityState) GetRef() *EntityState_Ref

+ func (x *EntityState) GetResourceType() EntityState_ResourceType

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

type EntityState_EntityType

+ const EntityState_BATCH_EXPORTER

+ const EntityState_STREAM

type EntityState_Ref

+ Type EntityState_EntityType

+ func (x *EntityState_Ref) GetType() EntityState_EntityType

+ type EntityState_ResourceType int32

+ const EntityState_BATCH_EXPORTER_DEPLOYMENT

+ const EntityState_BATCH_EXPORTER_SECRET

+ const EntityState_BATCH_JOB_DEPLOYMENT

+ const EntityState_BATCH_JOB_SECRET

+ const EntityState_RESOURCE_TYPE_UNSPECIFIED

+ const EntityState_STREAM_DECRYPTER_DEPLOYMENT

+ const EntityState_STREAM_ENCRYPTION_KEYS_TOPIC

+ const EntityState_STREAM_TOPIC

+ func (EntityState_ResourceType) Descriptor() protoreflect.EnumDescriptor

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

+ func (EntityState_ResourceType) Type() protoreflect.EnumType

+ func (x EntityState_ResourceType) Enum() *EntityState_ResourceType

+ func (x EntityState_ResourceType) Number() protoreflect.EnumNumber

+ func (x EntityState_ResourceType) String() string

type EntityState_Status

+ const EntityState_RESTARTING

+ type GetEntityStateRequest struct

+ ProjectionMask *fieldmaskpb.FieldMask

+ Ref *EntityState_Ref

+ Status EntityState_Status

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

+ func (*GetEntityStateRequest) ProtoMessage()

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

+ func (x *GetEntityStateRequest) GetRef() *EntityState_Ref

+ func (x *GetEntityStateRequest) GetStatus() EntityState_Status

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

+ func (x *GetEntityStateRequest) Reset()

+ func (x *GetEntityStateRequest) String() string

+ type GetEntityStateResponse struct

+ State *EntityState

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

+ func (*GetEntityStateResponse) ProtoMessage()

+ func (x *GetEntityStateResponse) GetState() *EntityState

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

+ func (x *GetEntityStateResponse) Reset()

+ func (x *GetEntityStateResponse) String() string

type MonitoringServiceClient

+ GetEntityState func(ctx context.Context, in *GetEntityStateRequest, opts ...grpc.CallOption) (MonitoringService_GetEntityStateClient, error)

type MonitoringServiceServer

+ GetEntityState func(*GetEntityStateRequest, MonitoringService_GetEntityStateServer) error

+ type MonitoringService_GetEntityStateClient interface

+ Recv func() (*GetEntityStateResponse, error)

+ type MonitoringService_GetEntityStateServer interface

+ Send func(*GetEntityStateResponse) error

type UnimplementedMonitoringServiceServer

+ func (UnimplementedMonitoringServiceServer) GetEntityState(*GetEntityStateRequest, MonitoringService_GetEntityStateServer) error

v2.65.1

Dec 6, 2022

v2.65.0

Dec 2, 2022

v2.64.0

Nov 30, 2022

v2.63.0

Nov 30, 2022

v2.62.0

Nov 24, 2022

Changes in this version

+ var EntityState_EntityType_name = map[int32]string

+ var EntityState_EntityType_value = map[string]int32

+ var EntityState_Status_name = map[int32]string

+ var EntityState_Status_value = map[string]int32

+ type EntityState struct

+ EntityRef *EntityState_Ref

+ Loglines []string

+ Message string

+ Status EntityState_Status

+ Value []float32

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

+ func (*EntityState) ProtoMessage()

+ 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 (x *EntityState) ProtoReflect() protoreflect.Message

+ func (x *EntityState) Reset()

+ func (x *EntityState) String() string

+ type EntityState_EntityType int32

+ const EntityState_BATCH_JOB

+ const EntityState_DERIVED_STREAM

+ const EntityState_ENTITY_TYPE_UNSPECIFIED

+ const EntityState_OMA

+ const EntityState_SCHEMA_REGISTRY

+ const EntityState_SOS

+ const EntityState_SOURCE_STREAM

+ func (EntityState_EntityType) Descriptor() protoreflect.EnumDescriptor

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

+ func (EntityState_EntityType) Type() protoreflect.EnumType

+ func (x EntityState_EntityType) Enum() *EntityState_EntityType

+ func (x EntityState_EntityType) Number() protoreflect.EnumNumber

+ func (x EntityState_EntityType) String() string

+ type EntityState_Ref struct

+ EntityType EntityState_EntityType

+ Id string

+ Name string

+ ProjectId string

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

+ func (*EntityState_Ref) ProtoMessage()

+ 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 (x *EntityState_Ref) ProtoReflect() protoreflect.Message

+ func (x *EntityState_Ref) Reset()

+ func (x *EntityState_Ref) String() string

+ type EntityState_Status int32

+ const EntityState_HEALTHY

+ const EntityState_PENDING

+ const EntityState_REMOVED

+ const EntityState_STATUS_UNSPECIFIED

+ const EntityState_TERMINATING

+ const EntityState_UNHEALTHY

+ func (EntityState_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (EntityState_Status) Type() protoreflect.EnumType

+ func (x EntityState_Status) Enum() *EntityState_Status

+ func (x EntityState_Status) Number() protoreflect.EnumNumber

+ func (x EntityState_Status) String() string

type MonitoringServiceClient

+ UpdateEntityStates func(ctx context.Context, opts ...grpc.CallOption) (MonitoringService_UpdateEntityStatesClient, error)

type MonitoringServiceServer

+ UpdateEntityStates func(MonitoringService_UpdateEntityStatesServer) error

+ type MonitoringService_UpdateEntityStatesClient interface

+ CloseAndRecv func() (*UpdateEntityStatesResponse, error)

+ Send func(*UpdateEntityStatesRequest) error

+ type MonitoringService_UpdateEntityStatesServer interface

+ Recv func() (*UpdateEntityStatesRequest, error)

+ SendAndClose func(*UpdateEntityStatesResponse) error

type UnimplementedMonitoringServiceServer

+ func (UnimplementedMonitoringServiceServer) UpdateEntityStates(MonitoringService_UpdateEntityStatesServer) error

+ type UpdateEntityStatesRequest struct

+ States []*EntityState

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

+ func (*UpdateEntityStatesRequest) ProtoMessage()

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

+ func (x *UpdateEntityStatesRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateEntityStatesRequest) Reset()

+ func (x *UpdateEntityStatesRequest) String() string

+ type UpdateEntityStatesResponse struct

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

+ func (*UpdateEntityStatesResponse) ProtoMessage()

+ func (x *UpdateEntityStatesResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateEntityStatesResponse) Reset()

+ func (x *UpdateEntityStatesResponse) String() string

v2.61.5

Nov 23, 2022

Changes in this version

+ var File_strmprivacy_api_monitoring_v1_monitoring_proto protoreflect.FileDescriptor

+ var MonitoringService_ServiceDesc = grpc.ServiceDesc

+ func RegisterMonitoringServiceServer(s grpc.ServiceRegistrar, srv MonitoringServiceServer)

+ type GetEntityStatesRequest struct

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

+ func (*GetEntityStatesRequest) ProtoMessage()

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

+ func (x *GetEntityStatesRequest) Reset()

+ func (x *GetEntityStatesRequest) String() string

+ type GetEntityStatesResponse struct

+ States []*GetEntityStatesResponse_State

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

+ func (*GetEntityStatesResponse) ProtoMessage()

+ func (x *GetEntityStatesResponse) GetStates() []*GetEntityStatesResponse_State

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

+ func (x *GetEntityStatesResponse) Reset()

+ func (x *GetEntityStatesResponse) String() string

+ type GetEntityStatesResponse_Ref struct

+ Id string

+ Name string

+ ProjectId string

+ func (*GetEntityStatesResponse_Ref) Descriptor() ([]byte, []int)

+ func (*GetEntityStatesResponse_Ref) ProtoMessage()

+ func (x *GetEntityStatesResponse_Ref) GetId() string

+ func (x *GetEntityStatesResponse_Ref) GetName() string

+ func (x *GetEntityStatesResponse_Ref) GetProjectId() string

+ func (x *GetEntityStatesResponse_Ref) ProtoReflect() protoreflect.Message

+ func (x *GetEntityStatesResponse_Ref) Reset()

+ func (x *GetEntityStatesResponse_Ref) String() string

+ type GetEntityStatesResponse_State struct

+ CustomerEntity bool

+ EntityRef *GetEntityStatesResponse_Ref

+ EntityType string

+ Message string

+ State string

+ func (*GetEntityStatesResponse_State) Descriptor() ([]byte, []int)

+ func (*GetEntityStatesResponse_State) ProtoMessage()

+ 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 (x *GetEntityStatesResponse_State) ProtoReflect() protoreflect.Message

+ func (x *GetEntityStatesResponse_State) Reset()

+ func (x *GetEntityStatesResponse_State) String() string

+ type MonitoringServiceClient interface

+ GetEntityStates func(ctx context.Context, in *GetEntityStatesRequest, opts ...grpc.CallOption) (MonitoringService_GetEntityStatesClient, error)

+ func NewMonitoringServiceClient(cc grpc.ClientConnInterface) MonitoringServiceClient

+ type MonitoringServiceServer interface

+ GetEntityStates func(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) error

+ type MonitoringService_GetEntityStatesClient interface

+ Recv func() (*GetEntityStatesResponse, error)

+ type MonitoringService_GetEntityStatesServer interface

+ Send func(*GetEntityStatesResponse) error

+ type UnimplementedMonitoringServiceServer struct

+ func (UnimplementedMonitoringServiceServer) GetEntityStates(*GetEntityStatesRequest, MonitoringService_GetEntityStatesServer) error

+ type UnsafeMonitoringServiceServer interface

Other modules containing this package

github.com/strmprivacy/api-definitions-go/v3

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