monitoring

package
v2.61.5 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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,
		},
	},
	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 (*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 (*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 (*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 (*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 (*GetEntityStatesResponse_State) Reset

func (x *GetEntityStatesResponse_State) Reset()

func (*GetEntityStatesResponse_State) 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.

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.

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.

Jump to

Keyboard shortcuts

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