Documentation ¶
Index ¶
- Variables
- func RegisterLogFormatterAgentServer(s grpc.ServiceRegistrar, srv LogFormatterAgentServer)
- type Error
- type ErrorType
- type HeartBeat
- func (*HeartBeat) Descriptor() ([]byte, []int)deprecated
- func (x *HeartBeat) GetConfig() []byte
- func (x *HeartBeat) GetRpcPort() string
- func (x *HeartBeat) GetStatus() Status
- func (*HeartBeat) ProtoMessage()
- func (x *HeartBeat) ProtoReflect() protoreflect.Message
- func (x *HeartBeat) Reset()
- func (x *HeartBeat) String() string
- type HeartBeatRequest
- type LogFormatterAgentClient
- type LogFormatterAgentServer
- type RequestHeader
- type ResponseHeader
- type Status
- type UnimplementedLogFormatterAgentServer
- type UnsafeLogFormatterAgentServer
- type UpdateConfigRequest
- func (*UpdateConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateConfigRequest) GetConfig() []byte
- func (x *UpdateConfigRequest) GetHeader() *RequestHeader
- func (*UpdateConfigRequest) ProtoMessage()
- func (x *UpdateConfigRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateConfigRequest) Reset()
- func (x *UpdateConfigRequest) String() string
- type UpdateConfigResponse
- func (*UpdateConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateConfigResponse) GetHeader() *ResponseHeader
- func (x *UpdateConfigResponse) GetHeartbeat() *HeartBeat
- func (*UpdateConfigResponse) ProtoMessage()
- func (x *UpdateConfigResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateConfigResponse) Reset()
- func (x *UpdateConfigResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ErrorType_name = map[int32]string{ 0: "OK", 1: "UNKOWN", 2: "FAILED", } ErrorType_value = map[string]int32{ "OK": 0, "UNKOWN": 1, "FAILED": 2, } )
Enum value maps for ErrorType.
var ( Status_name = map[int32]string{ 0: "Stop", 1: "Running", } Status_value = map[string]int32{ "Stop": 0, "Running": 1, } )
Enum value maps for Status.
var File_agent_agentpb_proto protoreflect.FileDescriptor
Functions ¶
func RegisterLogFormatterAgentServer ¶
func RegisterLogFormatterAgentServer(s grpc.ServiceRegistrar, srv LogFormatterAgentServer)
Types ¶
type Error ¶
type Error struct { Type ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=agentpb.ErrorType" json:"type,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type ErrorType ¶
type ErrorType int32
func (ErrorType) Descriptor ¶
func (ErrorType) Descriptor() protoreflect.EnumDescriptor
func (ErrorType) EnumDescriptor
deprecated
func (ErrorType) Number ¶
func (x ErrorType) Number() protoreflect.EnumNumber
func (ErrorType) Type ¶
func (ErrorType) Type() protoreflect.EnumType
type HeartBeat ¶
type HeartBeat struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=agentpb.Status" json:"status,omitempty"` RpcPort string `protobuf:"bytes,2,opt,name=rpcPort,proto3" json:"rpcPort,omitempty"` Config []byte `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*HeartBeat) Descriptor
deprecated
func (*HeartBeat) GetRpcPort ¶
func (*HeartBeat) ProtoMessage ¶
func (*HeartBeat) ProtoMessage()
func (*HeartBeat) ProtoReflect ¶
func (x *HeartBeat) ProtoReflect() protoreflect.Message
type HeartBeatRequest ¶
type HeartBeatRequest struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*HeartBeatRequest) Descriptor
deprecated
func (*HeartBeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartBeatRequest.ProtoReflect.Descriptor instead.
func (*HeartBeatRequest) GetHeader ¶
func (x *HeartBeatRequest) GetHeader() *ResponseHeader
func (*HeartBeatRequest) ProtoMessage ¶
func (*HeartBeatRequest) ProtoMessage()
func (*HeartBeatRequest) ProtoReflect ¶
func (x *HeartBeatRequest) ProtoReflect() protoreflect.Message
func (*HeartBeatRequest) Reset ¶
func (x *HeartBeatRequest) Reset()
func (*HeartBeatRequest) String ¶
func (x *HeartBeatRequest) String() string
type LogFormatterAgentClient ¶
type LogFormatterAgentClient interface { UpdateConfig(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error) GetHeartBeat(ctx context.Context, in *HeartBeatRequest, opts ...grpc.CallOption) (*HeartBeat, error) }
LogFormatterAgentClient is the client API for LogFormatterAgent 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 NewLogFormatterAgentClient ¶
func NewLogFormatterAgentClient(cc grpc.ClientConnInterface) LogFormatterAgentClient
type LogFormatterAgentServer ¶
type LogFormatterAgentServer interface { UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error) GetHeartBeat(context.Context, *HeartBeatRequest) (*HeartBeat, error) // contains filtered or unexported methods }
LogFormatterAgentServer is the server API for LogFormatterAgent service. All implementations must embed UnimplementedLogFormatterAgentServer for forward compatibility
type RequestHeader ¶
type RequestHeader struct {
// contains filtered or unexported fields
}
func (*RequestHeader) Descriptor
deprecated
func (*RequestHeader) Descriptor() ([]byte, []int)
Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) ProtoReflect ¶
func (x *RequestHeader) ProtoReflect() protoreflect.Message
func (*RequestHeader) Reset ¶
func (x *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (x *RequestHeader) String() string
type ResponseHeader ¶
type ResponseHeader struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ResponseHeader) Descriptor
deprecated
func (*ResponseHeader) Descriptor() ([]byte, []int)
Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.
func (*ResponseHeader) GetError ¶
func (x *ResponseHeader) GetError() *Error
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) ProtoReflect ¶
func (x *ResponseHeader) ProtoReflect() protoreflect.Message
func (*ResponseHeader) Reset ¶
func (x *ResponseHeader) Reset()
func (*ResponseHeader) String ¶
func (x *ResponseHeader) String() string
type Status ¶
type Status int32
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type UnimplementedLogFormatterAgentServer ¶
type UnimplementedLogFormatterAgentServer struct { }
UnimplementedLogFormatterAgentServer must be embedded to have forward compatible implementations.
func (UnimplementedLogFormatterAgentServer) GetHeartBeat ¶
func (UnimplementedLogFormatterAgentServer) GetHeartBeat(context.Context, *HeartBeatRequest) (*HeartBeat, error)
func (UnimplementedLogFormatterAgentServer) UpdateConfig ¶
func (UnimplementedLogFormatterAgentServer) UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error)
type UnsafeLogFormatterAgentServer ¶
type UnsafeLogFormatterAgentServer interface {
// contains filtered or unexported methods
}
UnsafeLogFormatterAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogFormatterAgentServer will result in compilation errors.
type UpdateConfigRequest ¶
type UpdateConfigRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Config []byte `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*UpdateConfigRequest) Descriptor
deprecated
func (*UpdateConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateConfigRequest.ProtoReflect.Descriptor instead.
func (*UpdateConfigRequest) GetConfig ¶
func (x *UpdateConfigRequest) GetConfig() []byte
func (*UpdateConfigRequest) GetHeader ¶
func (x *UpdateConfigRequest) GetHeader() *RequestHeader
func (*UpdateConfigRequest) ProtoMessage ¶
func (*UpdateConfigRequest) ProtoMessage()
func (*UpdateConfigRequest) ProtoReflect ¶
func (x *UpdateConfigRequest) ProtoReflect() protoreflect.Message
func (*UpdateConfigRequest) Reset ¶
func (x *UpdateConfigRequest) Reset()
func (*UpdateConfigRequest) String ¶
func (x *UpdateConfigRequest) String() string
type UpdateConfigResponse ¶
type UpdateConfigResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Heartbeat *HeartBeat `protobuf:"bytes,2,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"` // contains filtered or unexported fields }
func (*UpdateConfigResponse) Descriptor
deprecated
func (*UpdateConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateConfigResponse.ProtoReflect.Descriptor instead.
func (*UpdateConfigResponse) GetHeader ¶
func (x *UpdateConfigResponse) GetHeader() *ResponseHeader
func (*UpdateConfigResponse) GetHeartbeat ¶
func (x *UpdateConfigResponse) GetHeartbeat() *HeartBeat
func (*UpdateConfigResponse) ProtoMessage ¶
func (*UpdateConfigResponse) ProtoMessage()
func (*UpdateConfigResponse) ProtoReflect ¶
func (x *UpdateConfigResponse) ProtoReflect() protoreflect.Message
func (*UpdateConfigResponse) Reset ¶
func (x *UpdateConfigResponse) Reset()
func (*UpdateConfigResponse) String ¶
func (x *UpdateConfigResponse) String() string