Documentation ¶
Index ¶
- Variables
- func Handlers(h *sdk.Handler, d *driver)
- func NewDriver() (*driver, error)
- func RegisterIDockerLogDriverServer(s grpc.ServiceRegistrar, srv IDockerLogDriverServer)
- func RunService(lis net.Listener, d *driver)
- type CapabilitiesResponse
- type IDockerLogDriverClient
- type IDockerLogDriverServer
- type IDockerLogDriver_GetLogsClient
- type IDockerLogDriver_GetLogsServer
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetLine() []byte
- func (x *LogEntry) GetPartial() bool
- func (x *LogEntry) GetPartialLogMetadata() *PartialLogEntryMetadata
- func (x *LogEntry) GetSource() string
- func (x *LogEntry) GetTimeNano() int64
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type LogMessage
- type LogOptions
- type PartialLogEntryMetadata
- func (*PartialLogEntryMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *PartialLogEntryMetadata) GetId() string
- func (x *PartialLogEntryMetadata) GetLast() bool
- func (x *PartialLogEntryMetadata) GetOrdinal() int32
- func (*PartialLogEntryMetadata) ProtoMessage()
- func (x *PartialLogEntryMetadata) ProtoReflect() protoreflect.Message
- func (x *PartialLogEntryMetadata) Reset()
- func (x *PartialLogEntryMetadata) String() string
- type ReadLogsRequest
- type ServicesList
- type StartLoggingRequest
- type StopLoggingRequest
- type UnimplementedIDockerLogDriverServer
- type UnsafeIDockerLogDriverServer
Constants ¶
This section is empty.
Variables ¶
var File_logdriver_proto protoreflect.FileDescriptor
var IDockerLogDriver_ServiceDesc = grpc.ServiceDesc{ ServiceName: "logdriver.IDockerLogDriver", HandlerType: (*IDockerLogDriverServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListServices", Handler: _IDockerLogDriver_ListServices_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetLogs", Handler: _IDockerLogDriver_GetLogs_Handler, ServerStreams: true, }, }, Metadata: "logdriver.proto", }
IDockerLogDriver_ServiceDesc is the grpc.ServiceDesc for IDockerLogDriver service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIDockerLogDriverServer ¶
func RegisterIDockerLogDriverServer(s grpc.ServiceRegistrar, srv IDockerLogDriverServer)
func RunService ¶
Types ¶
type CapabilitiesResponse ¶
type CapabilitiesResponse struct { Err string Cap logger.Capability }
type IDockerLogDriverClient ¶
type IDockerLogDriverClient interface { GetLogs(ctx context.Context, in *LogOptions, opts ...grpc.CallOption) (IDockerLogDriver_GetLogsClient, error) ListServices(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServicesList, error) }
IDockerLogDriverClient is the client API for IDockerLogDriver 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 NewIDockerLogDriverClient ¶
func NewIDockerLogDriverClient(cc grpc.ClientConnInterface) IDockerLogDriverClient
type IDockerLogDriverServer ¶
type IDockerLogDriverServer interface { GetLogs(*LogOptions, IDockerLogDriver_GetLogsServer) error ListServices(context.Context, *emptypb.Empty) (*ServicesList, error) // contains filtered or unexported methods }
IDockerLogDriverServer is the server API for IDockerLogDriver service. All implementations must embed UnimplementedIDockerLogDriverServer for forward compatibility
type IDockerLogDriver_GetLogsClient ¶
type IDockerLogDriver_GetLogsClient interface { Recv() (*LogMessage, error) grpc.ClientStream }
type IDockerLogDriver_GetLogsServer ¶
type IDockerLogDriver_GetLogsServer interface { Send(*LogMessage) error grpc.ServerStream }
type LogEntry ¶
type LogEntry struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` TimeNano int64 `protobuf:"varint,2,opt,name=time_nano,json=timeNano,proto3" json:"time_nano,omitempty"` Line []byte `protobuf:"bytes,3,opt,name=line,proto3" json:"line,omitempty"` Partial bool `protobuf:"varint,4,opt,name=partial,proto3" json:"partial,omitempty"` PartialLogMetadata *PartialLogEntryMetadata `protobuf:"bytes,5,opt,name=partial_log_metadata,json=partialLogMetadata,proto3" json:"partial_log_metadata,omitempty"` // contains filtered or unexported fields }
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetPartial ¶
func (*LogEntry) GetPartialLogMetadata ¶
func (x *LogEntry) GetPartialLogMetadata() *PartialLogEntryMetadata
func (*LogEntry) GetTimeNano ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type LogMessage ¶
type LogMessage struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Entry *LogEntry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetEntry ¶
func (x *LogMessage) GetEntry() *LogEntry
func (*LogMessage) GetService ¶
func (x *LogMessage) GetService() string
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
type LogOptions ¶
type LogOptions struct {
// contains filtered or unexported fields
}
func (*LogOptions) Descriptor
deprecated
func (*LogOptions) Descriptor() ([]byte, []int)
Deprecated: Use LogOptions.ProtoReflect.Descriptor instead.
func (*LogOptions) ProtoMessage ¶
func (*LogOptions) ProtoMessage()
func (*LogOptions) ProtoReflect ¶
func (x *LogOptions) ProtoReflect() protoreflect.Message
func (*LogOptions) Reset ¶
func (x *LogOptions) Reset()
func (*LogOptions) String ¶
func (x *LogOptions) String() string
type PartialLogEntryMetadata ¶
type PartialLogEntryMetadata struct { Last bool `protobuf:"varint,1,opt,name=last,proto3" json:"last,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Ordinal int32 `protobuf:"varint,3,opt,name=ordinal,proto3" json:"ordinal,omitempty"` // contains filtered or unexported fields }
func (*PartialLogEntryMetadata) Descriptor
deprecated
func (*PartialLogEntryMetadata) Descriptor() ([]byte, []int)
Deprecated: Use PartialLogEntryMetadata.ProtoReflect.Descriptor instead.
func (*PartialLogEntryMetadata) GetId ¶
func (x *PartialLogEntryMetadata) GetId() string
func (*PartialLogEntryMetadata) GetLast ¶
func (x *PartialLogEntryMetadata) GetLast() bool
func (*PartialLogEntryMetadata) GetOrdinal ¶
func (x *PartialLogEntryMetadata) GetOrdinal() int32
func (*PartialLogEntryMetadata) ProtoMessage ¶
func (*PartialLogEntryMetadata) ProtoMessage()
func (*PartialLogEntryMetadata) ProtoReflect ¶
func (x *PartialLogEntryMetadata) ProtoReflect() protoreflect.Message
func (*PartialLogEntryMetadata) Reset ¶
func (x *PartialLogEntryMetadata) Reset()
func (*PartialLogEntryMetadata) String ¶
func (x *PartialLogEntryMetadata) String() string
type ReadLogsRequest ¶
type ReadLogsRequest struct { Info logger.Info Config logger.ReadConfig }
type ServicesList ¶
type ServicesList struct { Service []string `protobuf:"bytes,1,rep,name=service,proto3" json:"service,omitempty"` // contains filtered or unexported fields }
func (*ServicesList) Descriptor
deprecated
func (*ServicesList) Descriptor() ([]byte, []int)
Deprecated: Use ServicesList.ProtoReflect.Descriptor instead.
func (*ServicesList) GetService ¶
func (x *ServicesList) GetService() []string
func (*ServicesList) ProtoMessage ¶
func (*ServicesList) ProtoMessage()
func (*ServicesList) ProtoReflect ¶
func (x *ServicesList) ProtoReflect() protoreflect.Message
func (*ServicesList) Reset ¶
func (x *ServicesList) Reset()
func (*ServicesList) String ¶
func (x *ServicesList) String() string
type StartLoggingRequest ¶
type StopLoggingRequest ¶
type StopLoggingRequest struct {
File string
}
type UnimplementedIDockerLogDriverServer ¶
type UnimplementedIDockerLogDriverServer struct { }
UnimplementedIDockerLogDriverServer must be embedded to have forward compatible implementations.
func (UnimplementedIDockerLogDriverServer) GetLogs ¶
func (UnimplementedIDockerLogDriverServer) GetLogs(*LogOptions, IDockerLogDriver_GetLogsServer) error
func (UnimplementedIDockerLogDriverServer) ListServices ¶
func (UnimplementedIDockerLogDriverServer) ListServices(context.Context, *emptypb.Empty) (*ServicesList, error)
type UnsafeIDockerLogDriverServer ¶
type UnsafeIDockerLogDriverServer interface {
// contains filtered or unexported methods
}
UnsafeIDockerLogDriverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IDockerLogDriverServer will result in compilation errors.