health

package
v0.4.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2020 License: MPL-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HealthCheck_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheck_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var ReadyCheck_ReadyStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "READY",
	2: "NOT_READY",
}
View Source 
var ReadyCheck_ReadyStatus_value = map[string]int32{
	"UNKNOWN":   0,
	"READY":     1,
	"NOT_READY": 2,
}

Functions

func RegisterHealthServer 

func RegisterHealthServer(s *grpc.Server, srv HealthServer)

Types

type HealthCheck 

type HealthCheck struct {
	Status               HealthCheck_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=health.HealthCheck_ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) GetStatus 

func (m *HealthCheck) GetStatus() HealthCheck_ServingStatus

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck) XXX_Merge 

func (m *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

func (m *HealthCheck) XXX_Unmarshal(b []byte) error

type HealthCheckResponse 

type HealthCheckResponse struct {
	Messages             []*HealthCheck `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetMessages 

func (m *HealthCheckResponse) GetMessages() []*HealthCheck

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResponse) XXX_Merge 

func (m *HealthCheckResponse) XXX_Merge(src proto.Message)

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error

type HealthCheck_ServingStatus 

type HealthCheck_ServingStatus int32
const (
	HealthCheck_UNKNOWN     HealthCheck_ServingStatus = 0
	HealthCheck_SERVING     HealthCheck_ServingStatus = 1
	HealthCheck_NOT_SERVING HealthCheck_ServingStatus = 2
)

func (HealthCheck_ServingStatus) EnumDescriptor 

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

func (HealthCheck_ServingStatus) String 

func (x HealthCheck_ServingStatus) String() string

type HealthClient 

type HealthClient interface {
	Check(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Watch(ctx context.Context, in *HealthWatchRequest, opts ...grpc.CallOption) (Health_WatchClient, error)
	Ready(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ReadyCheckResponse, error)
}

HealthClient is the client API for Health service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHealthClient 

func NewHealthClient(cc *grpc.ClientConn) HealthClient

type HealthServer 

type HealthServer interface {
	Check(context.Context, *empty.Empty) (*HealthCheckResponse, error)
	Watch(*HealthWatchRequest, Health_WatchServer) error
	Ready(context.Context, *empty.Empty) (*ReadyCheckResponse, error)
}

HealthServer is the server API for Health service.

type HealthWatchRequest 

type HealthWatchRequest struct {
	IntervalSeconds      int64    `protobuf:"varint,1,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthWatchRequest) Descriptor 

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

func (*HealthWatchRequest) GetIntervalSeconds 

func (m *HealthWatchRequest) GetIntervalSeconds() int64

func (*HealthWatchRequest) ProtoMessage 

func (*HealthWatchRequest) ProtoMessage()

func (*HealthWatchRequest) Reset 

func (m *HealthWatchRequest) Reset()

func (*HealthWatchRequest) String 

func (m *HealthWatchRequest) String() string

func (*HealthWatchRequest) XXX_DiscardUnknown 

func (m *HealthWatchRequest) XXX_DiscardUnknown()

func (*HealthWatchRequest) XXX_Marshal 

func (m *HealthWatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthWatchRequest) XXX_Merge 

func (m *HealthWatchRequest) XXX_Merge(src proto.Message)

func (*HealthWatchRequest) XXX_Size 

func (m *HealthWatchRequest) XXX_Size() int

func (*HealthWatchRequest) XXX_Unmarshal 

func (m *HealthWatchRequest) XXX_Unmarshal(b []byte) error

type Health_WatchClient 

type Health_WatchClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type Health_WatchServer 

type Health_WatchServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

type ReadyCheck 

type ReadyCheck struct {
	Status               ReadyCheck_ReadyStatus `protobuf:"varint,1,opt,name=status,proto3,enum=health.ReadyCheck_ReadyStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReadyCheck) Descriptor 

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

func (*ReadyCheck) GetStatus 

func (m *ReadyCheck) GetStatus() ReadyCheck_ReadyStatus

func (*ReadyCheck) ProtoMessage 

func (*ReadyCheck) ProtoMessage()

func (*ReadyCheck) Reset 

func (m *ReadyCheck) Reset()

func (*ReadyCheck) String 

func (m *ReadyCheck) String() string

func (*ReadyCheck) XXX_DiscardUnknown 

func (m *ReadyCheck) XXX_DiscardUnknown()

func (*ReadyCheck) XXX_Marshal 

func (m *ReadyCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadyCheck) XXX_Merge 

func (m *ReadyCheck) XXX_Merge(src proto.Message)

func (*ReadyCheck) XXX_Size 

func (m *ReadyCheck) XXX_Size() int

func (*ReadyCheck) XXX_Unmarshal 

func (m *ReadyCheck) XXX_Unmarshal(b []byte) error

type ReadyCheckResponse 

type ReadyCheckResponse struct {
	Messages             []*ReadyCheck `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ReadyCheckResponse) Descriptor 

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

func (*ReadyCheckResponse) GetMessages 

func (m *ReadyCheckResponse) GetMessages() []*ReadyCheck

func (*ReadyCheckResponse) ProtoMessage 

func (*ReadyCheckResponse) ProtoMessage()

func (*ReadyCheckResponse) Reset 

func (m *ReadyCheckResponse) Reset()

func (*ReadyCheckResponse) String 

func (m *ReadyCheckResponse) String() string

func (*ReadyCheckResponse) XXX_DiscardUnknown 

func (m *ReadyCheckResponse) XXX_DiscardUnknown()

func (*ReadyCheckResponse) XXX_Marshal 

func (m *ReadyCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadyCheckResponse) XXX_Merge 

func (m *ReadyCheckResponse) XXX_Merge(src proto.Message)

func (*ReadyCheckResponse) XXX_Size 

func (m *ReadyCheckResponse) XXX_Size() int

func (*ReadyCheckResponse) XXX_Unmarshal 

func (m *ReadyCheckResponse) XXX_Unmarshal(b []byte) error

type ReadyCheck_ReadyStatus 

type ReadyCheck_ReadyStatus int32
const (
	ReadyCheck_UNKNOWN   ReadyCheck_ReadyStatus = 0
	ReadyCheck_READY     ReadyCheck_ReadyStatus = 1
	ReadyCheck_NOT_READY ReadyCheck_ReadyStatus = 2
)

func (ReadyCheck_ReadyStatus) EnumDescriptor 

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

func (ReadyCheck_ReadyStatus) String 

func (x ReadyCheck_ReadyStatus) String() string

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.