driver

package
v0.0.0-...-3eb36d8 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2023 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_logdriver_proto protoreflect.FileDescriptor
View Source
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 Handlers

func Handlers(h *sdk.Handler, d *driver)

func NewDriver

func NewDriver() (*driver, error)

func RegisterIDockerLogDriverServer

func RegisterIDockerLogDriverServer(s grpc.ServiceRegistrar, srv IDockerLogDriverServer)

func RunService

func RunService(lis net.Listener, d *driver)

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetLine

func (x *LogEntry) GetLine() []byte

func (*LogEntry) GetPartial

func (x *LogEntry) GetPartial() bool

func (*LogEntry) GetPartialLogMetadata

func (x *LogEntry) GetPartialLogMetadata() *PartialLogEntryMetadata

func (*LogEntry) GetSource

func (x *LogEntry) GetSource() string

func (*LogEntry) GetTimeNano

func (x *LogEntry) GetTimeNano() int64

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

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

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) String

func (x *LogEntry) String() string

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 StartLoggingRequest struct {
	File string
	Info logger.Info
}

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) ListServices

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL