Documentation ¶
Index ¶
- Variables
- func RegisterHealthServer(s *grpc.Server, srv HealthServer)
- func RegisterLoggerServer(s *grpc.Server, srv LoggerServer)
- type FilterDataRequest
- func (*FilterDataRequest) Descriptor() ([]byte, []int)
- func (m *FilterDataRequest) GetAppName() string
- func (m *FilterDataRequest) GetData() string
- func (m *FilterDataRequest) GetUrl() string
- func (*FilterDataRequest) ProtoMessage()
- func (m *FilterDataRequest) Reset()
- func (m *FilterDataRequest) String() string
- func (m *FilterDataRequest) XXX_DiscardUnknown()
- func (m *FilterDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FilterDataRequest) XXX_Merge(src proto.Message)
- func (m *FilterDataRequest) XXX_Size() int
- func (m *FilterDataRequest) XXX_Unmarshal(b []byte) error
- type FilterDataResponse
- func (*FilterDataResponse) Descriptor() ([]byte, []int)
- func (m *FilterDataResponse) GetErrorCode() int32
- func (m *FilterDataResponse) GetErrorMessage() string
- func (*FilterDataResponse) ProtoMessage()
- func (m *FilterDataResponse) Reset()
- func (m *FilterDataResponse) String() string
- func (m *FilterDataResponse) XXX_DiscardUnknown()
- func (m *FilterDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FilterDataResponse) XXX_Merge(src proto.Message)
- func (m *FilterDataResponse) XXX_Size() int
- func (m *FilterDataResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequest) GetService() string
- func (*HealthCheckRequest) ProtoMessage()
- func (m *HealthCheckRequest) Reset()
- func (m *HealthCheckRequest) String() string
- func (m *HealthCheckRequest) XXX_DiscardUnknown()
- func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckRequest) XXX_Merge(src proto.Message)
- func (m *HealthCheckRequest) XXX_Size() int
- func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)
- func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
- func (*HealthCheckResponse) ProtoMessage()
- func (m *HealthCheckResponse) Reset()
- func (m *HealthCheckResponse) String() string
- func (m *HealthCheckResponse) XXX_DiscardUnknown()
- func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckResponse) XXX_Merge(src proto.Message)
- func (m *HealthCheckResponse) XXX_Size() int
- func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckResponse_ServingStatus
- type HealthClient
- type HealthServer
- type LogInfo
- func (*LogInfo) Descriptor() ([]byte, []int)
- func (m *LogInfo) GetCreateTime() string
- func (m *LogInfo) GetException() string
- func (m *LogInfo) GetLevel() string
- func (m *LogInfo) GetLogType() string
- func (m *LogInfo) GetLogger() string
- func (m *LogInfo) GetMessage() string
- func (m *LogInfo) GetMsec() int64
- func (m *LogInfo) GetTimeSpan() string
- func (m *LogInfo) GetTraceId() string
- func (m *LogInfo) GetUserIp() string
- func (*LogInfo) ProtoMessage()
- func (m *LogInfo) Reset()
- func (m *LogInfo) String() string
- func (m *LogInfo) XXX_DiscardUnknown()
- func (m *LogInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogInfo) XXX_Merge(src proto.Message)
- func (m *LogInfo) XXX_Size() int
- func (m *LogInfo) XXX_Unmarshal(b []byte) error
- type LogInfoResponse
- func (*LogInfoResponse) Descriptor() ([]byte, []int)
- func (m *LogInfoResponse) GetErrorCode() int32
- func (m *LogInfoResponse) GetErrorMessage() string
- func (*LogInfoResponse) ProtoMessage()
- func (m *LogInfoResponse) Reset()
- func (m *LogInfoResponse) String() string
- func (m *LogInfoResponse) XXX_DiscardUnknown()
- func (m *LogInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogInfoResponse) XXX_Merge(src proto.Message)
- func (m *LogInfoResponse) XXX_Size() int
- func (m *LogInfoResponse) XXX_Unmarshal(b []byte) error
- type LoggerClient
- type LoggerServer
- type UnimplementedHealthServer
- type UnimplementedLoggerServer
Constants ¶
This section is empty.
Variables ¶
var HealthCheckResponse_ServingStatus_name = map[int32]string{
0: "UNKNOWN",
1: "SERVING",
2: "NOT_SERVING",
}
var HealthCheckResponse_ServingStatus_value = map[string]int32{
"UNKNOWN": 0,
"SERVING": 1,
"NOT_SERVING": 2,
}
Functions ¶
func RegisterHealthServer ¶
func RegisterHealthServer(s *grpc.Server, srv HealthServer)
func RegisterLoggerServer ¶
func RegisterLoggerServer(s *grpc.Server, srv LoggerServer)
Types ¶
type FilterDataRequest ¶
type FilterDataRequest struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` AppName string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"` Data string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FilterDataRequest) Descriptor ¶
func (*FilterDataRequest) Descriptor() ([]byte, []int)
func (*FilterDataRequest) GetAppName ¶
func (m *FilterDataRequest) GetAppName() string
func (*FilterDataRequest) GetData ¶
func (m *FilterDataRequest) GetData() string
func (*FilterDataRequest) GetUrl ¶
func (m *FilterDataRequest) GetUrl() string
func (*FilterDataRequest) ProtoMessage ¶
func (*FilterDataRequest) ProtoMessage()
func (*FilterDataRequest) Reset ¶
func (m *FilterDataRequest) Reset()
func (*FilterDataRequest) String ¶
func (m *FilterDataRequest) String() string
func (*FilterDataRequest) XXX_DiscardUnknown ¶
func (m *FilterDataRequest) XXX_DiscardUnknown()
func (*FilterDataRequest) XXX_Marshal ¶
func (m *FilterDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FilterDataRequest) XXX_Merge ¶
func (m *FilterDataRequest) XXX_Merge(src proto.Message)
func (*FilterDataRequest) XXX_Size ¶
func (m *FilterDataRequest) XXX_Size() int
func (*FilterDataRequest) XXX_Unmarshal ¶
func (m *FilterDataRequest) XXX_Unmarshal(b []byte) error
type FilterDataResponse ¶
type FilterDataResponse struct { ErrorCode int32 `protobuf:"varint,1,opt,name=errorCode,proto3" json:"errorCode,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FilterDataResponse) Descriptor ¶
func (*FilterDataResponse) Descriptor() ([]byte, []int)
func (*FilterDataResponse) GetErrorCode ¶
func (m *FilterDataResponse) GetErrorCode() int32
func (*FilterDataResponse) GetErrorMessage ¶
func (m *FilterDataResponse) GetErrorMessage() string
func (*FilterDataResponse) ProtoMessage ¶
func (*FilterDataResponse) ProtoMessage()
func (*FilterDataResponse) Reset ¶
func (m *FilterDataResponse) Reset()
func (*FilterDataResponse) String ¶
func (m *FilterDataResponse) String() string
func (*FilterDataResponse) XXX_DiscardUnknown ¶
func (m *FilterDataResponse) XXX_DiscardUnknown()
func (*FilterDataResponse) XXX_Marshal ¶
func (m *FilterDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FilterDataResponse) XXX_Merge ¶
func (m *FilterDataResponse) XXX_Merge(src proto.Message)
func (*FilterDataResponse) XXX_Size ¶
func (m *FilterDataResponse) XXX_Size() int
func (*FilterDataResponse) XXX_Unmarshal ¶
func (m *FilterDataResponse) XXX_Unmarshal(b []byte) error
type HealthCheckRequest ¶
type HealthCheckRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckRequest) Descriptor ¶
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
func (*HealthCheckRequest) GetService ¶
func (m *HealthCheckRequest) GetService() string
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) Reset ¶
func (m *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (m *HealthCheckRequest) String() string
func (*HealthCheckRequest) XXX_DiscardUnknown ¶
func (m *HealthCheckRequest) XXX_DiscardUnknown()
func (*HealthCheckRequest) XXX_Marshal ¶
func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckRequest) XXX_Merge ¶
func (m *HealthCheckRequest) XXX_Merge(src proto.Message)
func (*HealthCheckRequest) XXX_Size ¶
func (m *HealthCheckRequest) XXX_Size() int
func (*HealthCheckRequest) XXX_Unmarshal ¶
func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
type HealthCheckResponse ¶
type HealthCheckResponse struct { Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=pb.v1.HealthCheckResponse_ServingStatus" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckResponse) Descriptor ¶
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
func (*HealthCheckResponse) GetStatus ¶
func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
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 HealthCheckResponse_ServingStatus ¶
type HealthCheckResponse_ServingStatus int32
const ( HealthCheckResponse_UNKNOWN HealthCheckResponse_ServingStatus = 0 HealthCheckResponse_SERVING HealthCheckResponse_ServingStatus = 1 HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2 )
func (HealthCheckResponse_ServingStatus) EnumDescriptor ¶
func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)
func (HealthCheckResponse_ServingStatus) String ¶
func (x HealthCheckResponse_ServingStatus) String() string
type HealthClient ¶
type HealthClient interface {
Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, 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, *HealthCheckRequest) (*HealthCheckResponse, error)
}
HealthServer is the server API for Health service.
type LogInfo ¶
type LogInfo struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Msec int64 `protobuf:"varint,2,opt,name=msec,proto3" json:"msec,omitempty"` UserIp string `protobuf:"bytes,3,opt,name=userIp,proto3" json:"userIp,omitempty"` Exception string `protobuf:"bytes,4,opt,name=exception,proto3" json:"exception,omitempty"` TimeSpan string `protobuf:"bytes,5,opt,name=timeSpan,proto3" json:"timeSpan,omitempty"` Level string `protobuf:"bytes,6,opt,name=level,proto3" json:"level,omitempty"` Logger string `protobuf:"bytes,7,opt,name=logger,proto3" json:"logger,omitempty"` CreateTime string `protobuf:"bytes,8,opt,name=createTime,proto3" json:"createTime,omitempty"` LogType string `protobuf:"bytes,9,opt,name=logType,proto3" json:"logType,omitempty"` TraceId string `protobuf:"bytes,10,opt,name=traceId,proto3" json:"traceId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The request message containing the user's name.
func (*LogInfo) Descriptor ¶
func (*LogInfo) GetCreateTime ¶
func (*LogInfo) GetException ¶
func (*LogInfo) GetLogType ¶
func (*LogInfo) GetMessage ¶
func (*LogInfo) GetTimeSpan ¶
func (*LogInfo) GetTraceId ¶
func (*LogInfo) ProtoMessage ¶
func (*LogInfo) ProtoMessage()
func (*LogInfo) XXX_DiscardUnknown ¶
func (m *LogInfo) XXX_DiscardUnknown()
func (*LogInfo) XXX_Marshal ¶
func (*LogInfo) XXX_Unmarshal ¶
type LogInfoResponse ¶
type LogInfoResponse struct { ErrorCode int32 `protobuf:"varint,1,opt,name=errorCode,proto3" json:"errorCode,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The response message containing the greetings.
func (*LogInfoResponse) Descriptor ¶
func (*LogInfoResponse) Descriptor() ([]byte, []int)
func (*LogInfoResponse) GetErrorCode ¶
func (m *LogInfoResponse) GetErrorCode() int32
func (*LogInfoResponse) GetErrorMessage ¶
func (m *LogInfoResponse) GetErrorMessage() string
func (*LogInfoResponse) ProtoMessage ¶
func (*LogInfoResponse) ProtoMessage()
func (*LogInfoResponse) Reset ¶
func (m *LogInfoResponse) Reset()
func (*LogInfoResponse) String ¶
func (m *LogInfoResponse) String() string
func (*LogInfoResponse) XXX_DiscardUnknown ¶
func (m *LogInfoResponse) XXX_DiscardUnknown()
func (*LogInfoResponse) XXX_Marshal ¶
func (m *LogInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogInfoResponse) XXX_Merge ¶
func (m *LogInfoResponse) XXX_Merge(src proto.Message)
func (*LogInfoResponse) XXX_Size ¶
func (m *LogInfoResponse) XXX_Size() int
func (*LogInfoResponse) XXX_Unmarshal ¶
func (m *LogInfoResponse) XXX_Unmarshal(b []byte) error
type LoggerClient ¶
type LoggerClient interface { // Sends a greeting Info0(ctx context.Context, in *LogInfo, opts ...grpc.CallOption) (*LogInfoResponse, error) LogFilterData(ctx context.Context, in *FilterDataRequest, opts ...grpc.CallOption) (*FilterDataResponse, error) }
LoggerClient is the client API for Logger service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLoggerClient ¶
func NewLoggerClient(cc *grpc.ClientConn) LoggerClient
type LoggerServer ¶
type LoggerServer interface { // Sends a greeting Info0(context.Context, *LogInfo) (*LogInfoResponse, error) LogFilterData(context.Context, *FilterDataRequest) (*FilterDataResponse, error) }
LoggerServer is the server API for Logger service.
type UnimplementedHealthServer ¶
type UnimplementedHealthServer struct { }
UnimplementedHealthServer can be embedded to have forward compatible implementations.
func (*UnimplementedHealthServer) Check ¶
func (*UnimplementedHealthServer) Check(ctx context.Context, req *HealthCheckRequest) (*HealthCheckResponse, error)
type UnimplementedLoggerServer ¶
type UnimplementedLoggerServer struct { }
UnimplementedLoggerServer can be embedded to have forward compatible implementations.
func (*UnimplementedLoggerServer) Info0 ¶
func (*UnimplementedLoggerServer) Info0(ctx context.Context, req *LogInfo) (*LogInfoResponse, error)
func (*UnimplementedLoggerServer) LogFilterData ¶
func (*UnimplementedLoggerServer) LogFilterData(ctx context.Context, req *FilterDataRequest) (*FilterDataResponse, error)