Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterLogCollectorServer(s grpc.ServiceRegistrar, srv LogCollectorServer)
- type EventEntry
- func (*EventEntry) Descriptor() ([]byte, []int)deprecated
- func (x *EventEntry) GetComputationId() string
- func (x *EventEntry) GetDetails() []byte
- func (x *EventEntry) GetEventType() string
- func (x *EventEntry) GetOriginator() string
- func (x *EventEntry) GetStatus() string
- func (x *EventEntry) GetTimestamp() *timestamppb.Timestamp
- func (*EventEntry) ProtoMessage()
- func (x *EventEntry) ProtoReflect() protoreflect.Message
- func (x *EventEntry) Reset()
- func (x *EventEntry) String() string
- type LogCollectorClient
- type LogCollectorServer
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetComputationId() string
- func (x *LogEntry) GetLevel() string
- func (x *LogEntry) GetMessage() string
- func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type UnimplementedLogCollectorServer
- type UnsafeLogCollectorServer
Constants ¶
View Source
const ( LogCollector_SendLog_FullMethodName = "/log.LogCollector/SendLog" LogCollector_SendEvent_FullMethodName = "/log.LogCollector/SendEvent" )
Variables ¶
View Source
var File_agent_log_log_proto protoreflect.FileDescriptor
View Source
var LogCollector_ServiceDesc = grpc.ServiceDesc{ ServiceName: "log.LogCollector", HandlerType: (*LogCollectorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SendLog", Handler: _LogCollector_SendLog_Handler, }, { MethodName: "SendEvent", Handler: _LogCollector_SendEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "agent/log/log.proto", }
LogCollector_ServiceDesc is the grpc.ServiceDesc for LogCollector service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLogCollectorServer ¶
func RegisterLogCollectorServer(s grpc.ServiceRegistrar, srv LogCollectorServer)
Types ¶
type EventEntry ¶
type EventEntry struct {
EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
ComputationId string `protobuf:"bytes,3,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"`
Details []byte `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"` // JSON payload
Originator string `protobuf:"bytes,5,opt,name=originator,proto3" json:"originator,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*EventEntry) Descriptor
deprecated
func (*EventEntry) Descriptor() ([]byte, []int)
Deprecated: Use EventEntry.ProtoReflect.Descriptor instead.
func (*EventEntry) GetComputationId ¶
func (x *EventEntry) GetComputationId() string
func (*EventEntry) GetDetails ¶
func (x *EventEntry) GetDetails() []byte
func (*EventEntry) GetEventType ¶
func (x *EventEntry) GetEventType() string
func (*EventEntry) GetOriginator ¶
func (x *EventEntry) GetOriginator() string
func (*EventEntry) GetStatus ¶
func (x *EventEntry) GetStatus() string
func (*EventEntry) GetTimestamp ¶
func (x *EventEntry) GetTimestamp() *timestamppb.Timestamp
func (*EventEntry) ProtoMessage ¶
func (*EventEntry) ProtoMessage()
func (*EventEntry) ProtoReflect ¶
func (x *EventEntry) ProtoReflect() protoreflect.Message
func (*EventEntry) Reset ¶
func (x *EventEntry) Reset()
func (*EventEntry) String ¶
func (x *EventEntry) String() string
type LogCollectorClient ¶
type LogCollectorClient interface {
SendLog(ctx context.Context, in *LogEntry, opts ...grpc.CallOption) (*emptypb.Empty, error)
SendEvent(ctx context.Context, in *EventEntry, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
LogCollectorClient is the client API for LogCollector 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 NewLogCollectorClient ¶
func NewLogCollectorClient(cc grpc.ClientConnInterface) LogCollectorClient
type LogCollectorServer ¶
type LogCollectorServer interface {
SendLog(context.Context, *LogEntry) (*emptypb.Empty, error)
SendEvent(context.Context, *EventEntry) (*emptypb.Empty, error)
// contains filtered or unexported methods
}
LogCollectorServer is the server API for LogCollector service. All implementations must embed UnimplementedLogCollectorServer for forward compatibility.
type LogEntry ¶
type LogEntry struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
ComputationId string `protobuf:"bytes,2,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"`
Level string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetComputationId ¶
func (*LogEntry) GetMessage ¶
func (*LogEntry) GetTimestamp ¶
func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type UnimplementedLogCollectorServer ¶
type UnimplementedLogCollectorServer struct{}
UnimplementedLogCollectorServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLogCollectorServer) SendEvent ¶
func (UnimplementedLogCollectorServer) SendEvent(context.Context, *EventEntry) (*emptypb.Empty, error)
type UnsafeLogCollectorServer ¶
type UnsafeLogCollectorServer interface {
// contains filtered or unexported methods
}
UnsafeLogCollectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogCollectorServer will result in compilation errors.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.