rk_grpc_common_v1

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package rk_grpc_common_v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_api_v1_rk_common_service_proto protoreflect.FileDescriptor

Functions

func RegisterRkCommonServiceHandler 

func RegisterRkCommonServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRkCommonServiceHandler registers the http handlers for service RkCommonService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRkCommonServiceHandlerClient 

func RegisterRkCommonServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RkCommonServiceClient) error

RegisterRkCommonServiceHandlerClient registers the http handlers for service RkCommonService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RkCommonServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RkCommonServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RkCommonServiceClient" to call the correct interceptors.

func RegisterRkCommonServiceHandlerFromEndpoint 

func RegisterRkCommonServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRkCommonServiceHandlerFromEndpoint is same as RegisterRkCommonServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRkCommonServiceHandlerServer 

func RegisterRkCommonServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RkCommonServiceServer) error

RegisterRkCommonServiceHandlerServer registers the http handlers for service RkCommonService to "mux". UnaryRPC :call RkCommonServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRkCommonServiceHandlerFromEndpoint instead.

func RegisterRkCommonServiceServer 

func RegisterRkCommonServiceServer(s *grpc.Server, srv RkCommonServiceServer)

Types

type API added in v1.1.2 

type API struct {
	Name string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Grpc []*GRPC `protobuf:"bytes,2,rep,name=grpc,proto3" json:"grpc,omitempty"`
	Gw   []*GW   `protobuf:"bytes,3,rep,name=gw,proto3" json:"gw,omitempty"`
	// contains filtered or unexported fields
}

func (*API) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use API.ProtoReflect.Descriptor instead.

func (*API) GetGrpc added in v1.1.2 

func (x *API) GetGrpc() []*GRPC

func (*API) GetGw added in v1.1.2 

func (x *API) GetGw() []*GW

func (*API) GetName added in v1.1.2 

func (x *API) GetName() string

func (*API) ProtoMessage added in v1.1.2 

func (*API) ProtoMessage()

func (*API) ProtoReflect added in v1.1.2 

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

func (*API) Reset added in v1.1.2 

func (x *API) Reset()

func (*API) String added in v1.1.2 

func (x *API) String() string

type DumpConfigRequest 

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

func (*DumpConfigRequest) Descriptor deprecated 

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

Deprecated: Use DumpConfigRequest.ProtoReflect.Descriptor instead.

func (*DumpConfigRequest) ProtoMessage 

func (*DumpConfigRequest) ProtoMessage()

func (*DumpConfigRequest) ProtoReflect 

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

func (*DumpConfigRequest) Reset 

func (x *DumpConfigRequest) Reset()

func (*DumpConfigRequest) String 

func (x *DumpConfigRequest) String() string

type DumpConfigResponse 

type DumpConfigResponse struct {
	Viper []*Viper `protobuf:"bytes,1,rep,name=viper,proto3" json:"viper,omitempty"`
	Rk    []*RK    `protobuf:"bytes,2,rep,name=rk,proto3" json:"rk,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpConfigResponse) Descriptor deprecated 

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

Deprecated: Use DumpConfigResponse.ProtoReflect.Descriptor instead.

func (*DumpConfigResponse) GetRk 

func (x *DumpConfigResponse) GetRk() []*RK

func (*DumpConfigResponse) GetViper 

func (x *DumpConfigResponse) GetViper() []*Viper

func (*DumpConfigResponse) ProtoMessage 

func (*DumpConfigResponse) ProtoMessage()

func (*DumpConfigResponse) ProtoReflect 

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

func (*DumpConfigResponse) Reset 

func (x *DumpConfigResponse) Reset()

func (*DumpConfigResponse) String 

func (x *DumpConfigResponse) String() string

type GCRequest 

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

GC request, operator must be set

func (*GCRequest) Descriptor deprecated 

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

Deprecated: Use GCRequest.ProtoReflect.Descriptor instead.

func (*GCRequest) ProtoMessage 

func (*GCRequest) ProtoMessage()

func (*GCRequest) ProtoReflect 

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

func (*GCRequest) Reset 

func (x *GCRequest) Reset()

func (*GCRequest) String 

func (x *GCRequest) String() string

type GCResponse 

type GCResponse struct {
	MemStatsBeforeGc *MemStats `protobuf:"bytes,1,opt,name=mem_stats_before_gc,json=memStatsBeforeGc,proto3" json:"mem_stats_before_gc,omitempty"`
	MemStatsAfterGc  *MemStats `protobuf:"bytes,2,opt,name=mem_stats_after_gc,json=memStatsAfterGc,proto3" json:"mem_stats_after_gc,omitempty"`
	// contains filtered or unexported fields
}

GC response, memory stats would be returned

func (*GCResponse) Descriptor deprecated 

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

Deprecated: Use GCResponse.ProtoReflect.Descriptor instead.

func (*GCResponse) GetMemStatsAfterGc 

func (x *GCResponse) GetMemStatsAfterGc() *MemStats

func (*GCResponse) GetMemStatsBeforeGc 

func (x *GCResponse) GetMemStatsBeforeGc() *MemStats

func (*GCResponse) ProtoMessage 

func (*GCResponse) ProtoMessage()

func (*GCResponse) ProtoReflect 

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

func (*GCResponse) Reset 

func (x *GCResponse) Reset()

func (*GCResponse) String 

func (x *GCResponse) String() string

type GRPC added in v1.1.2 

type GRPC struct {
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Method  string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Type    string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Port    uint32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*GRPC) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use GRPC.ProtoReflect.Descriptor instead.

func (*GRPC) GetMethod added in v1.1.2 

func (x *GRPC) GetMethod() string

func (*GRPC) GetPort added in v1.1.2 

func (x *GRPC) GetPort() uint32

func (*GRPC) GetService added in v1.1.2 

func (x *GRPC) GetService() string

func (*GRPC) GetType added in v1.1.2 

func (x *GRPC) GetType() string

func (*GRPC) ProtoMessage added in v1.1.2 

func (*GRPC) ProtoMessage()

func (*GRPC) ProtoReflect added in v1.1.2 

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

func (*GRPC) Reset added in v1.1.2 

func (x *GRPC) Reset()

func (*GRPC) String added in v1.1.2 

func (x *GRPC) String() string

type GW added in v1.1.2 

type GW struct {
	Port   uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Sw     string `protobuf:"bytes,4,opt,name=sw,proto3" json:"sw,omitempty"`
	// contains filtered or unexported fields
}

func (*GW) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use GW.ProtoReflect.Descriptor instead.

func (*GW) GetMethod added in v1.1.2 

func (x *GW) GetMethod() string

func (*GW) GetPath added in v1.1.2 

func (x *GW) GetPath() string

func (*GW) GetPort added in v1.1.2 

func (x *GW) GetPort() uint32

func (*GW) GetSw added in v1.1.2 

func (x *GW) GetSw() string

func (*GW) ProtoMessage added in v1.1.2 

func (*GW) ProtoMessage()

func (*GW) ProtoReflect added in v1.1.2 

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

func (*GW) Reset added in v1.1.2 

func (x *GW) Reset()

func (*GW) String added in v1.1.2 

func (x *GW) String() string

type HealthyRequest 

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

func (*HealthyRequest) Descriptor deprecated 

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

Deprecated: Use HealthyRequest.ProtoReflect.Descriptor instead.

func (*HealthyRequest) ProtoMessage 

func (*HealthyRequest) ProtoMessage()

func (*HealthyRequest) ProtoReflect 

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

func (*HealthyRequest) Reset 

func (x *HealthyRequest) Reset()

func (*HealthyRequest) String 

func (x *HealthyRequest) String() string

type HealthyResponse 

type HealthyResponse struct {
	Healthy bool `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthyResponse) Descriptor deprecated 

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

Deprecated: Use HealthyResponse.ProtoReflect.Descriptor instead.

func (*HealthyResponse) GetHealthy 

func (x *HealthyResponse) GetHealthy() bool

func (*HealthyResponse) ProtoMessage 

func (*HealthyResponse) ProtoMessage()

func (*HealthyResponse) ProtoReflect 

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

func (*HealthyResponse) Reset 

func (x *HealthyResponse) Reset()

func (*HealthyResponse) String 

func (x *HealthyResponse) String() string

type Info 

type Info struct {
	Uid         string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid         string `protobuf:"bytes,2,opt,name=gid,proto3" json:"gid,omitempty"`
	Username    string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	StartTime   string `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	UpTimeSec   uint32 `protobuf:"varint,5,opt,name=up_time_sec,json=upTimeSec,proto3" json:"up_time_sec,omitempty"`
	UpTimeStr   string `protobuf:"bytes,6,opt,name=up_time_str,json=upTimeStr,proto3" json:"up_time_str,omitempty"`
	Application string `protobuf:"bytes,7,opt,name=application,proto3" json:"application,omitempty"`
	Realm       string `protobuf:"bytes,8,opt,name=realm,proto3" json:"realm,omitempty"`
	Region      string `protobuf:"bytes,9,opt,name=region,proto3" json:"region,omitempty"`
	Az          string `protobuf:"bytes,10,opt,name=az,proto3" json:"az,omitempty"`
	Domain      string `protobuf:"bytes,11,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*Info) Descriptor deprecated 

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

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) GetApplication 

func (x *Info) GetApplication() string

func (*Info) GetAz 

func (x *Info) GetAz() string

func (*Info) GetDomain 

func (x *Info) GetDomain() string

func (*Info) GetGid 

func (x *Info) GetGid() string

func (*Info) GetRealm 

func (x *Info) GetRealm() string

func (*Info) GetRegion 

func (x *Info) GetRegion() string

func (*Info) GetStartTime 

func (x *Info) GetStartTime() string

func (*Info) GetUid 

func (x *Info) GetUid() string

func (*Info) GetUpTimeSec 

func (x *Info) GetUpTimeSec() uint32

func (*Info) GetUpTimeStr 

func (x *Info) GetUpTimeStr() string

func (*Info) GetUsername 

func (x *Info) GetUsername() string

func (*Info) ProtoMessage 

func (*Info) ProtoMessage()

func (*Info) ProtoReflect 

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

func (*Info) Reset 

func (x *Info) Reset()

func (*Info) String 

func (x *Info) String() string

type InfoRequest 

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

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

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

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetInfo 

func (x *InfoResponse) GetInfo() *Info

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

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

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type ListAPIRequest added in v1.1.2 

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

func (*ListAPIRequest) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ListAPIRequest.ProtoReflect.Descriptor instead.

func (*ListAPIRequest) ProtoMessage added in v1.1.2 

func (*ListAPIRequest) ProtoMessage()

func (*ListAPIRequest) ProtoReflect added in v1.1.2 

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

func (*ListAPIRequest) Reset added in v1.1.2 

func (x *ListAPIRequest) Reset()

func (*ListAPIRequest) String added in v1.1.2 

func (x *ListAPIRequest) String() string

type ListAPIResponse added in v1.1.2 

type ListAPIResponse struct {
	Api []*API `protobuf:"bytes,1,rep,name=api,proto3" json:"api,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAPIResponse) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ListAPIResponse.ProtoReflect.Descriptor instead.

func (*ListAPIResponse) GetApi added in v1.1.2 

func (x *ListAPIResponse) GetApi() []*API

func (*ListAPIResponse) ProtoMessage added in v1.1.2 

func (*ListAPIResponse) ProtoMessage()

func (*ListAPIResponse) ProtoReflect added in v1.1.2 

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

func (*ListAPIResponse) Reset added in v1.1.2 

func (x *ListAPIResponse) Reset()

func (*ListAPIResponse) String added in v1.1.2 

func (x *ListAPIResponse) String() string

type MemStats 

type MemStats struct {

	// Alloc is bytes of allocated heap objects.
	MemAllocByte uint32 `protobuf:"varint,1,opt,name=mem_alloc_byte,json=memAllocByte,proto3" json:"mem_alloc_byte,omitempty"`
	// Sys is the total bytes of memory obtained from the OS.
	SysAllocByte uint32 `protobuf:"varint,2,opt,name=sys_alloc_byte,json=sysAllocByte,proto3" json:"sys_alloc_byte,omitempty"`
	// memory usage
	MemUsagePercentage float32 `protobuf:"fixed32,3,opt,name=mem_usage_percentage,json=memUsagePercentage,proto3" json:"mem_usage_percentage,omitempty"`
	// LastGC is the time the last garbage collection finished.
	// Represent as RFC3339 time format
	LastGcTimestamp string `protobuf:"bytes,4,opt,name=last_gc_timestamp,json=lastGcTimestamp,proto3" json:"last_gc_timestamp,omitempty"`
	// The number of completed GC cycles.
	GcCountTotal uint32 `protobuf:"varint,5,opt,name=gc_count_total,json=gcCountTotal,proto3" json:"gc_count_total,omitempty"`
	/// The number of GC cycles that were forced by
	// the application calling the GC function.
	ForceGcCount uint32 `protobuf:"varint,6,opt,name=force_gc_count,json=forceGcCount,proto3" json:"force_gc_count,omitempty"`
	// contains filtered or unexported fields
}

Memory stats

func (*MemStats) Descriptor deprecated 

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

Deprecated: Use MemStats.ProtoReflect.Descriptor instead.

func (*MemStats) GetForceGcCount 

func (x *MemStats) GetForceGcCount() uint32

func (*MemStats) GetGcCountTotal 

func (x *MemStats) GetGcCountTotal() uint32

func (*MemStats) GetLastGcTimestamp 

func (x *MemStats) GetLastGcTimestamp() string

func (*MemStats) GetMemAllocByte 

func (x *MemStats) GetMemAllocByte() uint32

func (*MemStats) GetMemUsagePercentage 

func (x *MemStats) GetMemUsagePercentage() float32

func (*MemStats) GetSysAllocByte 

func (x *MemStats) GetSysAllocByte() uint32

func (*MemStats) ProtoMessage 

func (*MemStats) ProtoMessage()

func (*MemStats) ProtoReflect 

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

func (*MemStats) Reset 

func (x *MemStats) Reset()

func (*MemStats) String 

func (x *MemStats) String() string

type RK 

type RK struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Raw  string `protobuf:"bytes,2,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*RK) Descriptor deprecated 

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

Deprecated: Use RK.ProtoReflect.Descriptor instead.

func (*RK) GetName 

func (x *RK) GetName() string

func (*RK) GetRaw 

func (x *RK) GetRaw() string

func (*RK) ProtoMessage 

func (*RK) ProtoMessage()

func (*RK) ProtoReflect 

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

func (*RK) Reset 

func (x *RK) Reset()

func (*RK) String 

func (x *RK) String() string

type ReqMetricsRK added in v1.1.2 

type ReqMetricsRK struct {
	Path            string       `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	ElapsedNanoP50  float32      `protobuf:"fixed32,2,opt,name=elapsed_nano_p50,json=elapsedNanoP50,proto3" json:"elapsed_nano_p50,omitempty"`
	ElapsedNanoP90  float32      `protobuf:"fixed32,3,opt,name=elapsed_nano_p90,json=elapsedNanoP90,proto3" json:"elapsed_nano_p90,omitempty"`
	ElapsedNanoP99  float32      `protobuf:"fixed32,4,opt,name=elapsed_nano_p99,json=elapsedNanoP99,proto3" json:"elapsed_nano_p99,omitempty"`
	ElapsedNanoP999 float32      `protobuf:"fixed32,5,opt,name=elapsed_nano_p999,json=elapsedNanoP999,proto3" json:"elapsed_nano_p999,omitempty"`
	Count           uint32       `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	ResCode         []*ResCodeRK `protobuf:"bytes,7,rep,name=res_code,json=resCode,proto3" json:"res_code,omitempty"`
	// contains filtered or unexported fields
}

func (*ReqMetricsRK) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ReqMetricsRK.ProtoReflect.Descriptor instead.

func (*ReqMetricsRK) GetCount added in v1.1.2 

func (x *ReqMetricsRK) GetCount() uint32

func (*ReqMetricsRK) GetElapsedNanoP50 added in v1.1.2 

func (x *ReqMetricsRK) GetElapsedNanoP50() float32

func (*ReqMetricsRK) GetElapsedNanoP90 added in v1.1.2 

func (x *ReqMetricsRK) GetElapsedNanoP90() float32

func (*ReqMetricsRK) GetElapsedNanoP99 added in v1.1.2 

func (x *ReqMetricsRK) GetElapsedNanoP99() float32

func (*ReqMetricsRK) GetElapsedNanoP999 added in v1.1.2 

func (x *ReqMetricsRK) GetElapsedNanoP999() float32

func (*ReqMetricsRK) GetPath added in v1.1.2 

func (x *ReqMetricsRK) GetPath() string

func (*ReqMetricsRK) GetResCode added in v1.1.2 

func (x *ReqMetricsRK) GetResCode() []*ResCodeRK

func (*ReqMetricsRK) ProtoMessage added in v1.1.2 

func (*ReqMetricsRK) ProtoMessage()

func (*ReqMetricsRK) ProtoReflect added in v1.1.2 

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

func (*ReqMetricsRK) Reset added in v1.1.2 

func (x *ReqMetricsRK) Reset()

func (*ReqMetricsRK) String added in v1.1.2 

func (x *ReqMetricsRK) String() string

type ReqRequest added in v1.1.2 

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

func (*ReqRequest) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ReqRequest.ProtoReflect.Descriptor instead.

func (*ReqRequest) ProtoMessage added in v1.1.2 

func (*ReqRequest) ProtoMessage()

func (*ReqRequest) ProtoReflect added in v1.1.2 

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

func (*ReqRequest) Reset added in v1.1.2 

func (x *ReqRequest) Reset()

func (*ReqRequest) String added in v1.1.2 

func (x *ReqRequest) String() string

type ReqResponse added in v1.1.2 

type ReqResponse struct {
	Metrics []*ReqMetricsRK `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ReqResponse) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ReqResponse.ProtoReflect.Descriptor instead.

func (*ReqResponse) GetMetrics added in v1.1.2 

func (x *ReqResponse) GetMetrics() []*ReqMetricsRK

func (*ReqResponse) ProtoMessage added in v1.1.2 

func (*ReqResponse) ProtoMessage()

func (*ReqResponse) ProtoReflect added in v1.1.2 

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

func (*ReqResponse) Reset added in v1.1.2 

func (x *ReqResponse) Reset()

func (*ReqResponse) String added in v1.1.2 

func (x *ReqResponse) String() string

type ResCodeRK added in v1.1.2 

type ResCodeRK struct {
	ResCode string `protobuf:"bytes,1,opt,name=res_code,json=resCode,proto3" json:"res_code,omitempty"`
	Count   uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ResCodeRK) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use ResCodeRK.ProtoReflect.Descriptor instead.

func (*ResCodeRK) GetCount added in v1.1.2 

func (x *ResCodeRK) GetCount() uint32

func (*ResCodeRK) GetResCode added in v1.1.2 

func (x *ResCodeRK) GetResCode() string

func (*ResCodeRK) ProtoMessage added in v1.1.2 

func (*ResCodeRK) ProtoMessage()

func (*ResCodeRK) ProtoReflect added in v1.1.2 

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

func (*ResCodeRK) Reset added in v1.1.2 

func (x *ResCodeRK) Reset()

func (*ResCodeRK) String added in v1.1.2 

func (x *ResCodeRK) String() string

type RkCommonServiceClient 

type RkCommonServiceClient interface {
	// GC Stub
	GC(ctx context.Context, in *GCRequest, opts ...grpc.CallOption) (*GCResponse, error)
	// Config Stub
	Config(ctx context.Context, in *DumpConfigRequest, opts ...grpc.CallOption) (*DumpConfigResponse, error)
	// Info Stub
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// Healthy Stub
	Healthy(ctx context.Context, in *HealthyRequest, opts ...grpc.CallOption) (*HealthyResponse, error)
	// List API Stub
	APIS(ctx context.Context, in *ListAPIRequest, opts ...grpc.CallOption) (*ListAPIResponse, error)
	// Sys Stub
	Sys(ctx context.Context, in *SysRequest, opts ...grpc.CallOption) (*SysResponse, error)
	// Req Stub
	Req(ctx context.Context, in *ReqRequest, opts ...grpc.CallOption) (*ReqResponse, error)
}

RkCommonServiceClient is the client API for RkCommonService service.

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

func NewRkCommonServiceClient 

func NewRkCommonServiceClient(cc grpc.ClientConnInterface) RkCommonServiceClient

type RkCommonServiceServer 

type RkCommonServiceServer interface {
	// GC Stub
	GC(context.Context, *GCRequest) (*GCResponse, error)
	// Config Stub
	Config(context.Context, *DumpConfigRequest) (*DumpConfigResponse, error)
	// Info Stub
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	// Healthy Stub
	Healthy(context.Context, *HealthyRequest) (*HealthyResponse, error)
	// List API Stub
	APIS(context.Context, *ListAPIRequest) (*ListAPIResponse, error)
	// Sys Stub
	Sys(context.Context, *SysRequest) (*SysResponse, error)
	// Req Stub
	Req(context.Context, *ReqRequest) (*ReqResponse, error)
}

RkCommonServiceServer is the server API for RkCommonService service.

type SysRequest added in v1.1.2 

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

func (*SysRequest) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use SysRequest.ProtoReflect.Descriptor instead.

func (*SysRequest) ProtoMessage added in v1.1.2 

func (*SysRequest) ProtoMessage()

func (*SysRequest) ProtoReflect added in v1.1.2 

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

func (*SysRequest) Reset added in v1.1.2 

func (x *SysRequest) Reset()

func (*SysRequest) String added in v1.1.2 

func (x *SysRequest) String() string

type SysResponse added in v1.1.2 

type SysResponse struct {
	CpuPercentage float32 `protobuf:"fixed32,1,opt,name=cpu_percentage,json=cpuPercentage,proto3" json:"cpu_percentage,omitempty"`
	MemPercentage float32 `protobuf:"fixed32,2,opt,name=mem_percentage,json=memPercentage,proto3" json:"mem_percentage,omitempty"`
	MemUsageMb    uint32  `protobuf:"varint,3,opt,name=mem_usage_mb,json=memUsageMb,proto3" json:"mem_usage_mb,omitempty"`
	UpTime        string  `protobuf:"bytes,4,opt,name=up_time,json=upTime,proto3" json:"up_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SysResponse) Descriptor deprecated added in v1.1.2 

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

Deprecated: Use SysResponse.ProtoReflect.Descriptor instead.

func (*SysResponse) GetCpuPercentage added in v1.1.2 

func (x *SysResponse) GetCpuPercentage() float32

func (*SysResponse) GetMemPercentage added in v1.1.2 

func (x *SysResponse) GetMemPercentage() float32

func (*SysResponse) GetMemUsageMb added in v1.1.2 

func (x *SysResponse) GetMemUsageMb() uint32

func (*SysResponse) GetUpTime added in v1.1.2 

func (x *SysResponse) GetUpTime() string

func (*SysResponse) ProtoMessage added in v1.1.2 

func (*SysResponse) ProtoMessage()

func (*SysResponse) ProtoReflect added in v1.1.2 

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

func (*SysResponse) Reset added in v1.1.2 

func (x *SysResponse) Reset()

func (*SysResponse) String added in v1.1.2 

func (x *SysResponse) String() string

type UnimplementedRkCommonServiceServer 

type UnimplementedRkCommonServiceServer struct {
}

UnimplementedRkCommonServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRkCommonServiceServer) APIS added in v1.1.2 

func (*UnimplementedRkCommonServiceServer) APIS(context.Context, *ListAPIRequest) (*ListAPIResponse, error)

func (*UnimplementedRkCommonServiceServer) Config added in v1.1.2 

func (*UnimplementedRkCommonServiceServer) Config(context.Context, *DumpConfigRequest) (*DumpConfigResponse, error)

func (*UnimplementedRkCommonServiceServer) GC 

func (*UnimplementedRkCommonServiceServer) GC(context.Context, *GCRequest) (*GCResponse, error)

func (*UnimplementedRkCommonServiceServer) Healthy 

func (*UnimplementedRkCommonServiceServer) Healthy(context.Context, *HealthyRequest) (*HealthyResponse, error)

func (*UnimplementedRkCommonServiceServer) Info 

func (*UnimplementedRkCommonServiceServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (*UnimplementedRkCommonServiceServer) Req added in v1.1.2 

func (*UnimplementedRkCommonServiceServer) Req(context.Context, *ReqRequest) (*ReqResponse, error)

func (*UnimplementedRkCommonServiceServer) Sys added in v1.1.2 

func (*UnimplementedRkCommonServiceServer) Sys(context.Context, *SysRequest) (*SysResponse, error)

type Viper 

type Viper struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Raw  string `protobuf:"bytes,2,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Viper) Descriptor deprecated 

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

Deprecated: Use Viper.ProtoReflect.Descriptor instead.

func (*Viper) GetName 

func (x *Viper) GetName() string

func (*Viper) GetRaw 

func (x *Viper) GetRaw() string

func (*Viper) ProtoMessage 

func (*Viper) ProtoMessage()

func (*Viper) ProtoReflect 

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

func (*Viper) Reset 

func (x *Viper) Reset()

func (*Viper) String 

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