healthz

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2024 License: Apache-2.0 Imports: 11 Imported by: 7

README

gNOI Healthz Streaming RPC Design

Contributors: hines@google.com, robjs@google.com, bneville@arista.com, roman.dodin@nokia.com Last Updated: 2022-11-02

Background

The purpose of Healthz is to allow a component inside of a system to report its health. The concept of asking "Are you healthy?" is a general design principle in distributed systems.

The ability to also include "implementation specific" details about the health of the system or component is very standard for network devices in the form for "show tech", "diag" or "debug" commands. These are very useful for getting diagnostics about the system state to the implementers. Healthz exposes these interfaces as queryable endpoints to allow operators to validate "health" on components and if "unhealthy" gather implementor specific data to help triage or reproduce issues.

Design Background

Healthz provides a means by which a user may initiate checks of health (through the Check RPC) or a system may report the results of a check that it has initiated of its own accord.

Following a health check occurring, a caller uses the List or Get RPC to discover the health "events" (expressed as a ComponentStatus message) that are associated with a component and its corresponding subcomponents. Each event reflects a collection of data that is required to debug or further root cause the fault that occurs with an entity in the system.

The Artifact RPC is used to retrieve specific artifacts that are listed by the target system in the List or Get RPC. Once retrieved an event, which corresponds to a series of artifacts, can be 'acknowledged' by the client of the RPC. Acknowledged events are no longer returned in the list of events by default. The device may use the acknowledged status as a hint to allow garbage collection of artifacts that are no longer relevant. The device itself is responsible for garbage collection any may, if necessary, garbage collect artifacts that are not yet acknowledged. It is expected that events are persisted across restarts of the system or its hardware and software components, and they are removed only for resource management reasons.

Whilst the system may initiate health checks itself, these should be safe to perform operations that do not impact the device's functionality. Expensive checks (e.g., pausing protocols, or dumping internal database state) that are potentially service impacting should require use of the Check RPC.

Healthz works in conjunction with telemetry streamed via gNMI, OpenConfig paths for a specific component are streamed to indicate when components become unhealthy, allowing the receiving system to determine that further inspection of the component's health is required. The following paths (defined in the openconfig-platform model) are used:

component/healthz/state/status          (enumerated value)
component/healthz/state/last-unhealthy  (timestamp)
component/healthz/state/unhealthy-count (int64)
Choice of Streaming for Artifacts

Background comment

Originally, the gNOI Healthz endpoint defined single transactional API for getting the "healthz" status of a component. As discussed in the above issue, due to large data volume or to an interactive debug output there is a requirement that it support the ability to stream a status from the device.

To ensure that this can be done using a secure channel with the relevant ACL and encryption, this streaming is implemented within the Healthz service. This approach further allows the concept of a historical set of collected artifacts to be reported by the device.

Collection of Artifacts

As described above, by default health checks that are performed automatically by the device SHOULD NOT be performance impacting. The Check RPC is used to ensure the creation of artifacts that are expensive to collect.

Thus -- a system relying on healthz for reporting of device status, needs to consider the following workflow.

  1. A component of the system becomes unhealthy. The device MUST generate a health state via telemetry that indicates that the healthz/state/status of the component has transitioned to UNHEALTHY. It is left for the device implementor to determine which artifacts are generated automatically by the system immediately. The artifact collection SHOULD NOT impact the performance of the system.
  2. The responding client system observes the transition to UNHEALTHY and can List events that have occurred on the component. The client SHOULD be aware that not all artifacts that may be required may have automatically been collected and a Check RPC may be required to collect the artifacts that were considered performance impacting. This allows the client systems to co-ordinate to reduce the operational risk of collecting this data (e.g, by removing traffic from the network device). In order to specify that the Check refers to a previously reported event, the event_id field in the request must be populated with the ID reported in Get or List.
  3. If the component becomes healthy again, even if no Healthz calls were made to the system, telemetry information MUST be updated to ensure that external clients are updated as to the current health status.

In order that the relevant information for a particular event is collected, the device SHOULD ensure that the non-system-impacting artifact collection that is performed at the time of the event is sufficient that error conditions can be understood and debugged.

Architecture

Use of gNMI paths

Where a gNMI path (gnoi.types.Path) is used in Healthz, the path specified should be the complete path to a specific component - i.e., /components/component[name=FOO].

Healthz.Get()
rpc Get(GetRequest) returns (GetResponse) {}

Get allows a user to retrieve the latest set of health statuses that are associated with a specific component and any of its corresponding subcomponents. In contrast to List the Get RPC should return only the latest event (i.e., ComponentStatus message).

The GetResponse returned includes a ComponentStatus message which corresponds to the latest health event for the component itself and each subcomponent being reported on. Thus, multiple ComponentStatus messages may be reported for a single component. Each message includes a set of ArtifactHeader messages that correspond to the health event -- and provide identifiers and types for the artifacts that can be returned by the system.

All artifacts that are listed within the same ComponentStatus message are expected to have a shared acknowledgement state, and expiry time.

Healthz.List()
rpc List(ListRequest) returns (ListResponse) {}

List returns all events that are associated with a particular component. In contrast to Get, it returns all events that the target has for the device. By default, events that are acknowledged are not returned.

List returns a series of ComponentStatus messages. These messages have the same semantics as those that are returned by the Get RPC, described above.

Healthz.Acknowledge()
rpc Acknowledge(AcknowledgeRequest) returns (AcknowledgeResponse) {}

Acknowledge is used by a client to indicate to the target device that a particular (component, event) tuple has been retrieved by the client. This allows a device to intelligently determine whether to retain artifacts. Devices MUST ensure that artifact storage for healthz does not cause resource exhaustion and SHOULD remove acknowledged artifacts before those that have not yet received an acknowledgment.

Healthz.Artifact()
rpc Artifact(ArtifactRequest) returns (stream ArtifactResponse) {}

Artifact allows a user to retrieve a specific artifact that is related to an event that has occurred. Since these artifacts may be large, the Artifact RPC is implemented as a server-side streaming RPC. The Artifact RPC ensures that a target sends these potentially large artifacts only when explicitly requested by the client.

Each artifact that is returned in the Artifact RPC call should contain ArtifactResponses in the following order:

  • ArtifactHeader
  • one or more bytes/proto
  • ArtifactTrailer
Healthz.Check()
rpc Check(CheckRequest) returns (CheckResponse) {}

Check allows a client to execute a set of "validations" against the specified component. The component, as with other operations, is specified in terms of the gNMI path.

The result of the Check produces a healthz ComponentStatus message which will contain a list of the generated artifacts used in the validation process.

A call to the Check endpoint will allow for "very expensive" debugging commands such as causing the device to pause and snapshot its system database or to examine the state of a protocol. These commands will likely be considered "service impacting" and should have a clear security ACL restricting their use during normal operations of the device.

The CheckRequest message includes an event_id field. When populated this indicates that the Check should be performed for an event that has already occurred within the system. The device should trigger artifact collection of those artifacts that were not automatically collected. A CheckRequest for a previous event_id MUST NOT overwrite previous artifacts that were collected at the time of the event. The artifacts that are collected MUST be returned in the artifact list for the event when reported by the Get or List RPCs.

User Experience

A BGP routing process goes unhealthy due to a crash.
Expected Action

Write the core dump to a file system.

A call to Healthz.Get should respond with the current state of the component and provide feedback that there is an artifact available to be requested.

A Healthz.Artifact() call should stream the core dump over the service back to the caller.

The component that is specified should correspond to the software process that implements the BGP protocol in the system.

A chassis linecard goes unhealthy due to hardware failure.
Expected Action

Logs / dumps collected and the gNMI components are marked unhealthy.

A call to Healthz.Get should respond with the current state of the component and provide feedback that there is an artifact available to be requested.

A Healthz.Artifact() call should stream the core dump over the service back to the caller.

A Healthz.Artifact() call should stream the logs over the service back to the caller.

The component that is reported on should be of type CHASSIS.

A chassis file storage is over a configured capacity and reports itself unhealthy.

Since there are no artifacts the Healthz.Get should just return the status of the component and no other action is necessary

The component reported on via telemetry should correspond to the device's chassis and be of type CHASSIS.

A user would like to stream console debugging or other shell output for collection

For a component healthz could be used to provide an I/O dump of a specific debugging command redirected as a byte stream. It could also be output like a top or show interfaces where the data is periodically updated (each "frame" would be sent over the stream as a separate message). This would allow for show tech like information to be collected and sent to vendors in a programmatic secure way but not completely reinventing the wheel.

To achieve this use case, extensions to the existing specification are required.

Collect a snapshot of a particular component.

For components which can provide a "snapshot" of state the healthz artifact endpoint can be provided to take a snapshot of state (ideally serialized as a protobuf or other typed data structure) and provided to the caller.

Examples:

  • Get optical data from i2c bus on optical systems.
  • Get system database state for the core pub/sub of a device.
Exporting internal or specific debug logs

For a component in the system the developers could provide a debug log for that specific component or other trace / dump information. The Check() and Artifact() APIs could be used in these cases to create the setup and then download the specific data in a secure, reliable way (rather than a general file scp). If the device can "automatically" generate these specific data the Get API can also be used to check for existence and to download the artifacts. Note that to support this use case, additional gNMI paths are likely required to signal existence of this type of data.

Event lifecycle

An event is created internally by the system for a linecard rebooting unexpectedly. The chassis process will take a core of the component. Snapshot it's log for the component. Snapshot any relevant state in a system database for the component and create a healthz event which includes pointers to these 3 artifacts.

The external monitoring system will receive a gNMI update reporting that the specific component became unhealthy.

An event monitoring agent can then call the healthz service specifying the faulty component, and thus retrieve the current event and the associated artifacts. Since the component becoming healthy is an externally reportable event (i.e., may need to be reported to the vendor to initiate an RMA) the system decides to retrieve the artifacts and store them within a bug tracking system case. Once the artifacts are retrieved the system will mark the event as acknowledged and the server can then use its local retention policy to clean up those events.

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_HEALTHY",
		2: "STATUS_UNHEALTHY",
	}
	Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_HEALTHY":     1,
		"STATUS_UNHEALTHY":   2,
	}
)

Enum value maps for Status.

View Source 
var File_healthz_healthz_proto protoreflect.FileDescriptor
View Source 
var Healthz_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gnoi.healthz.Healthz",
	HandlerType: (*HealthzServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Healthz_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Healthz_List_Handler,
		},
		{
			MethodName: "Acknowledge",
			Handler:    _Healthz_Acknowledge_Handler,
		},
		{
			MethodName: "Check",
			Handler:    _Healthz_Check_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Artifact",
			Handler:       _Healthz_Artifact_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "healthz/healthz.proto",
}

Healthz_ServiceDesc is the grpc.ServiceDesc for Healthz service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHealthzServer 

func RegisterHealthzServer(s grpc.ServiceRegistrar, srv HealthzServer)

Types

type AcknowledgeRequest 

type AcknowledgeRequest struct {
	Path *types.Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Id   string      `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgeRequest) Descriptor deprecated 

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

Deprecated: Use AcknowledgeRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgeRequest) GetId 

func (x *AcknowledgeRequest) GetId() string

func (*AcknowledgeRequest) GetPath 

func (x *AcknowledgeRequest) GetPath() *types.Path

func (*AcknowledgeRequest) ProtoMessage 

func (*AcknowledgeRequest) ProtoMessage()

func (*AcknowledgeRequest) ProtoReflect 

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

func (*AcknowledgeRequest) Reset 

func (x *AcknowledgeRequest) Reset()

func (*AcknowledgeRequest) String 

func (x *AcknowledgeRequest) String() string

type AcknowledgeResponse 

type AcknowledgeResponse struct {
	Status *ComponentStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgeResponse) Descriptor deprecated 

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

Deprecated: Use AcknowledgeResponse.ProtoReflect.Descriptor instead.

func (*AcknowledgeResponse) GetStatus 

func (x *AcknowledgeResponse) GetStatus() *ComponentStatus

func (*AcknowledgeResponse) ProtoMessage 

func (*AcknowledgeResponse) ProtoMessage()

func (*AcknowledgeResponse) ProtoReflect 

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

func (*AcknowledgeResponse) Reset 

func (x *AcknowledgeResponse) Reset()

func (*AcknowledgeResponse) String 

func (x *AcknowledgeResponse) String() string

type ArtifactHeader 

type ArtifactHeader struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to ArtifactType:
	//
	//	*ArtifactHeader_File
	//	*ArtifactHeader_Proto
	//	*ArtifactHeader_Custom
	ArtifactType isArtifactHeader_ArtifactType `protobuf_oneof:"artifact_type"`
	// contains filtered or unexported fields
}

func (*ArtifactHeader) Descriptor deprecated 

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

Deprecated: Use ArtifactHeader.ProtoReflect.Descriptor instead.

func (*ArtifactHeader) GetArtifactType 

func (m *ArtifactHeader) GetArtifactType() isArtifactHeader_ArtifactType

func (*ArtifactHeader) GetCustom 

func (x *ArtifactHeader) GetCustom() *anypb.Any

func (*ArtifactHeader) GetFile 

func (x *ArtifactHeader) GetFile() *FileArtifactType

func (*ArtifactHeader) GetId 

func (x *ArtifactHeader) GetId() string

func (*ArtifactHeader) GetProto 

func (x *ArtifactHeader) GetProto() *ProtoArtifactType

func (*ArtifactHeader) ProtoMessage 

func (*ArtifactHeader) ProtoMessage()

func (*ArtifactHeader) ProtoReflect 

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

func (*ArtifactHeader) Reset 

func (x *ArtifactHeader) Reset()

func (*ArtifactHeader) String 

func (x *ArtifactHeader) String() string

type ArtifactHeader_Custom 

type ArtifactHeader_Custom struct {
	Custom *anypb.Any `protobuf:"bytes,103,opt,name=custom,proto3,oneof"`
}

type ArtifactHeader_File 

type ArtifactHeader_File struct {
	File *FileArtifactType `protobuf:"bytes,101,opt,name=file,proto3,oneof"`
}

type ArtifactHeader_Proto 

type ArtifactHeader_Proto struct {
	Proto *ProtoArtifactType `protobuf:"bytes,102,opt,name=proto,proto3,oneof"`
}

type ArtifactRequest 

type ArtifactRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactRequest) Descriptor deprecated 

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

Deprecated: Use ArtifactRequest.ProtoReflect.Descriptor instead.

func (*ArtifactRequest) GetId 

func (x *ArtifactRequest) GetId() string

func (*ArtifactRequest) ProtoMessage 

func (*ArtifactRequest) ProtoMessage()

func (*ArtifactRequest) ProtoReflect 

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

func (*ArtifactRequest) Reset 

func (x *ArtifactRequest) Reset()

func (*ArtifactRequest) String 

func (x *ArtifactRequest) String() string

type ArtifactResponse 

type ArtifactResponse struct {

	// Types that are assignable to Contents:
	//
	//	*ArtifactResponse_Header
	//	*ArtifactResponse_Trailer
	//	*ArtifactResponse_Bytes
	//	*ArtifactResponse_Proto
	Contents isArtifactResponse_Contents `protobuf_oneof:"contents"`
	// contains filtered or unexported fields
}

func (*ArtifactResponse) Descriptor deprecated 

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

Deprecated: Use ArtifactResponse.ProtoReflect.Descriptor instead.

func (*ArtifactResponse) GetBytes 

func (x *ArtifactResponse) GetBytes() []byte

func (*ArtifactResponse) GetContents 

func (m *ArtifactResponse) GetContents() isArtifactResponse_Contents

func (*ArtifactResponse) GetHeader 

func (x *ArtifactResponse) GetHeader() *ArtifactHeader

func (*ArtifactResponse) GetProto 

func (x *ArtifactResponse) GetProto() *anypb.Any

func (*ArtifactResponse) GetTrailer 

func (x *ArtifactResponse) GetTrailer() *ArtifactTrailer

func (*ArtifactResponse) ProtoMessage 

func (*ArtifactResponse) ProtoMessage()

func (*ArtifactResponse) ProtoReflect 

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

func (*ArtifactResponse) Reset 

func (x *ArtifactResponse) Reset()

func (*ArtifactResponse) String 

func (x *ArtifactResponse) String() string

type ArtifactResponse_Bytes 

type ArtifactResponse_Bytes struct {
	Bytes []byte `protobuf:"bytes,3,opt,name=bytes,proto3,oneof"`
}

type ArtifactResponse_Header 

type ArtifactResponse_Header struct {
	Header *ArtifactHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type ArtifactResponse_Proto 

type ArtifactResponse_Proto struct {
	Proto *anypb.Any `protobuf:"bytes,4,opt,name=proto,proto3,oneof"`
}

type ArtifactResponse_Trailer 

type ArtifactResponse_Trailer struct {
	Trailer *ArtifactTrailer `protobuf:"bytes,2,opt,name=trailer,proto3,oneof"`
}

type ArtifactTrailer 

type ArtifactTrailer struct {
	// contains filtered or unexported fields
}

func (*ArtifactTrailer) Descriptor deprecated 

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

Deprecated: Use ArtifactTrailer.ProtoReflect.Descriptor instead.

func (*ArtifactTrailer) ProtoMessage 

func (*ArtifactTrailer) ProtoMessage()

func (*ArtifactTrailer) ProtoReflect 

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

func (*ArtifactTrailer) Reset 

func (x *ArtifactTrailer) Reset()

func (*ArtifactTrailer) String 

func (x *ArtifactTrailer) String() string

type CheckRequest 

type CheckRequest struct {
	Path    *types.Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	EventId string      `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckRequest) Descriptor deprecated 

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

Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.

func (*CheckRequest) GetEventId 

func (x *CheckRequest) GetEventId() string

func (*CheckRequest) GetPath 

func (x *CheckRequest) GetPath() *types.Path

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) ProtoReflect 

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

func (*CheckRequest) Reset 

func (x *CheckRequest) Reset()

func (*CheckRequest) String 

func (x *CheckRequest) String() string

type CheckResponse 

type CheckResponse struct {
	Status *ComponentStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckResponse) Descriptor deprecated 

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

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) GetStatus 

func (x *CheckResponse) GetStatus() *ComponentStatus

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect 

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

func (*CheckResponse) Reset 

func (x *CheckResponse) Reset()

func (*CheckResponse) String 

func (x *CheckResponse) String() string

type ComponentStatus 

type ComponentStatus struct {
	Path          *types.Path        `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Subcomponents []*ComponentStatus `protobuf:"bytes,2,rep,name=subcomponents,proto3" json:"subcomponents,omitempty"`
	Status        Status             `protobuf:"varint,3,opt,name=status,proto3,enum=gnoi.healthz.Status" json:"status,omitempty"`
	// Deprecated: Marked as deprecated in healthz/healthz.proto.
	Healthz      *anypb.Any             `protobuf:"bytes,4,opt,name=healthz,proto3" json:"healthz,omitempty"`
	Artifacts    []*ArtifactHeader      `protobuf:"bytes,5,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	Id           string                 `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	Acknowledged bool                   `protobuf:"varint,7,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	Created      *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created,proto3" json:"created,omitempty"`
	Expires      *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentStatus) Descriptor deprecated 

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

Deprecated: Use ComponentStatus.ProtoReflect.Descriptor instead.

func (*ComponentStatus) GetAcknowledged 

func (x *ComponentStatus) GetAcknowledged() bool

func (*ComponentStatus) GetArtifacts 

func (x *ComponentStatus) GetArtifacts() []*ArtifactHeader

func (*ComponentStatus) GetCreated 

func (x *ComponentStatus) GetCreated() *timestamppb.Timestamp

func (*ComponentStatus) GetExpires 

func (x *ComponentStatus) GetExpires() *timestamppb.Timestamp

func (*ComponentStatus) GetHealthz deprecated 

func (x *ComponentStatus) GetHealthz() *anypb.Any

Deprecated: Marked as deprecated in healthz/healthz.proto.

func (*ComponentStatus) GetId 

func (x *ComponentStatus) GetId() string

func (*ComponentStatus) GetPath 

func (x *ComponentStatus) GetPath() *types.Path

func (*ComponentStatus) GetStatus 

func (x *ComponentStatus) GetStatus() Status

func (*ComponentStatus) GetSubcomponents 

func (x *ComponentStatus) GetSubcomponents() []*ComponentStatus

func (*ComponentStatus) ProtoMessage 

func (*ComponentStatus) ProtoMessage()

func (*ComponentStatus) ProtoReflect 

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

func (*ComponentStatus) Reset 

func (x *ComponentStatus) Reset()

func (*ComponentStatus) String 

func (x *ComponentStatus) String() string

type FileArtifactType 

type FileArtifactType struct {
	Name     string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path     string          `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Mimetype string          `protobuf:"bytes,3,opt,name=mimetype,proto3" json:"mimetype,omitempty"`
	Size     int64           `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Hash     *types.HashType `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*FileArtifactType) Descriptor deprecated 

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

Deprecated: Use FileArtifactType.ProtoReflect.Descriptor instead.

func (*FileArtifactType) GetHash 

func (x *FileArtifactType) GetHash() *types.HashType

func (*FileArtifactType) GetMimetype 

func (x *FileArtifactType) GetMimetype() string

func (*FileArtifactType) GetName 

func (x *FileArtifactType) GetName() string

func (*FileArtifactType) GetPath 

func (x *FileArtifactType) GetPath() string

func (*FileArtifactType) GetSize 

func (x *FileArtifactType) GetSize() int64

func (*FileArtifactType) ProtoMessage 

func (*FileArtifactType) ProtoMessage()

func (*FileArtifactType) ProtoReflect 

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

func (*FileArtifactType) Reset 

func (x *FileArtifactType) Reset()

func (*FileArtifactType) String 

func (x *FileArtifactType) String() string

type GetRequest 

type GetRequest struct {
	Path *types.Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetPath 

func (x *GetRequest) GetPath() *types.Path

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Component *ComponentStatus `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetComponent 

func (x *GetResponse) GetComponent() *ComponentStatus

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type HealthzClient 

type HealthzClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*AcknowledgeResponse, error)
	Artifact(ctx context.Context, in *ArtifactRequest, opts ...grpc.CallOption) (Healthz_ArtifactClient, error)
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
}

HealthzClient is the client API for Healthz 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 NewHealthzClient 

func NewHealthzClient(cc grpc.ClientConnInterface) HealthzClient

type HealthzServer 

type HealthzServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Acknowledge(context.Context, *AcknowledgeRequest) (*AcknowledgeResponse, error)
	Artifact(*ArtifactRequest, Healthz_ArtifactServer) error
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	// contains filtered or unexported methods
}

HealthzServer is the server API for Healthz service. All implementations must embed UnimplementedHealthzServer for forward compatibility

type Healthz_ArtifactClient 

type Healthz_ArtifactClient interface {
	Recv() (*ArtifactResponse, error)
	grpc.ClientStream
}

type Healthz_ArtifactServer 

type Healthz_ArtifactServer interface {
	Send(*ArtifactResponse) error
	grpc.ServerStream
}

type ListRequest 

type ListRequest struct {
	Path                *types.Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	IncludeAcknowledged bool        `protobuf:"varint,2,opt,name=include_acknowledged,json=includeAcknowledged,proto3" json:"include_acknowledged,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetIncludeAcknowledged 

func (x *ListRequest) GetIncludeAcknowledged() bool

func (*ListRequest) GetPath 

func (x *ListRequest) GetPath() *types.Path

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Statuses []*ComponentStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetStatuses 

func (x *ListResponse) GetStatuses() []*ComponentStatus

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type ProtoArtifactType 

type ProtoArtifactType struct {
	// contains filtered or unexported fields
}

func (*ProtoArtifactType) Descriptor deprecated 

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

Deprecated: Use ProtoArtifactType.ProtoReflect.Descriptor instead.

func (*ProtoArtifactType) ProtoMessage 

func (*ProtoArtifactType) ProtoMessage()

func (*ProtoArtifactType) ProtoReflect 

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

func (*ProtoArtifactType) Reset 

func (x *ProtoArtifactType) Reset()

func (*ProtoArtifactType) String 

func (x *ProtoArtifactType) String() string

type Status 

type Status int32
const (
	Status_STATUS_UNSPECIFIED Status = 0
	Status_STATUS_HEALTHY     Status = 1
	Status_STATUS_UNHEALTHY   Status = 2
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type UnimplementedHealthzServer 

type UnimplementedHealthzServer struct {
}

UnimplementedHealthzServer must be embedded to have forward compatible implementations.

func (UnimplementedHealthzServer) Acknowledge 

func (UnimplementedHealthzServer) Acknowledge(context.Context, *AcknowledgeRequest) (*AcknowledgeResponse, error)

func (UnimplementedHealthzServer) Artifact 

func (UnimplementedHealthzServer) Artifact(*ArtifactRequest, Healthz_ArtifactServer) error

func (UnimplementedHealthzServer) Check 

func (UnimplementedHealthzServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)

func (UnimplementedHealthzServer) Get 

func (UnimplementedHealthzServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedHealthzServer) List 

func (UnimplementedHealthzServer) List(context.Context, *ListRequest) (*ListResponse, error)

type UnsafeHealthzServer 

type UnsafeHealthzServer interface {
	// contains filtered or unexported methods
}

UnsafeHealthzServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthzServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.