plugin

package
v0.0.0-...-5e8511f Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2023 License: AGPL-3.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FileInfoProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "leichtcloud.fileinfo.plugin.FileInfoProvider",
	HandlerType: (*FileInfoProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MinimumBytes",
			Handler:    _FileInfoProvider_MinimumBytes_Handler,
		},
		{
			MethodName: "Render",
			Handler:    _FileInfoProvider_Render_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Check",
			Handler:       _FileInfoProvider_Check_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "fileinfo.proto",
}

FileInfoProvider_ServiceDesc is the grpc.ServiceDesc for FileInfoProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_fileinfo_proto protoreflect.FileDescriptor

Functions

func RegisterFileInfoProviderServer 

func RegisterFileInfoProviderServer(s grpc.ServiceRegistrar, srv FileInfoProviderServer)

func Start 

func Start(fileinfo types.FileInfoProvider) (err error)

This is meant to be called in the main() of your plugin

Types

type BridgeFileinfoProviderServer 

type BridgeFileinfoProviderServer struct {
	FileInfo types.FileInfoProvider
}

func NewFileinfoBridge 

func NewFileinfoBridge(fileinfo types.FileInfoProvider) *BridgeFileinfoProviderServer

func (*BridgeFileinfoProviderServer) Check 

func (s *BridgeFileinfoProviderServer) Check(srv FileInfoProvider_CheckServer) error

func (*BridgeFileinfoProviderServer) MinimumBytes 

func (s *BridgeFileinfoProviderServer) MinimumBytes(_ context.Context, req *MinimumBytesQuery) (*MinimumBytesResponse, error)

func (*BridgeFileinfoProviderServer) Render 

func (s *BridgeFileinfoProviderServer) Render(_ context.Context, req *RenderQuery) (*RenderResponse, error)

type CheckQuery 

type CheckQuery struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	EOF      bool   `protobuf:"varint,3,opt,name=EOF,proto3" json:"EOF,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckQuery) Descriptor deprecated 

func (*CheckQuery) Descriptor() ([]byte, []int)

Deprecated: Use CheckQuery.ProtoReflect.Descriptor instead.

func (*CheckQuery) GetData 

func (x *CheckQuery) GetData() []byte

func (*CheckQuery) GetEOF 

func (x *CheckQuery) GetEOF() bool

func (*CheckQuery) GetFilename 

func (x *CheckQuery) GetFilename() string

func (*CheckQuery) ProtoMessage 

func (*CheckQuery) ProtoMessage()

func (*CheckQuery) ProtoReflect 

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

func (*CheckQuery) Reset 

func (x *CheckQuery) Reset()

func (*CheckQuery) String 

func (x *CheckQuery) String() string

type CheckResponse 

type CheckResponse struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckResponse) Descriptor deprecated 

func (*CheckResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) GetData 

func (x *CheckResponse) GetData() []byte

func (*CheckResponse) GetError 

func (x *CheckResponse) GetError() *Error

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect 

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

func (*CheckResponse) Reset 

func (x *CheckResponse) Reset()

func (*CheckResponse) String 

func (x *CheckResponse) String() string

type Error 

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FileInfoProviderClient 

type FileInfoProviderClient interface {
	MinimumBytes(ctx context.Context, in *MinimumBytesQuery, opts ...grpc.CallOption) (*MinimumBytesResponse, error)
	Check(ctx context.Context, opts ...grpc.CallOption) (FileInfoProvider_CheckClient, error)
	Render(ctx context.Context, in *RenderQuery, opts ...grpc.CallOption) (*RenderResponse, error)
}

FileInfoProviderClient is the client API for FileInfoProvider 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 NewFileInfoProviderClient 

func NewFileInfoProviderClient(cc grpc.ClientConnInterface) FileInfoProviderClient

type FileInfoProviderServer 

type FileInfoProviderServer interface {
	MinimumBytes(context.Context, *MinimumBytesQuery) (*MinimumBytesResponse, error)
	Check(FileInfoProvider_CheckServer) error
	Render(context.Context, *RenderQuery) (*RenderResponse, error)
	// contains filtered or unexported methods
}

FileInfoProviderServer is the server API for FileInfoProvider service. All implementations must embed UnimplementedFileInfoProviderServer for forward compatibility

type FileInfoProvider_CheckClient 

type FileInfoProvider_CheckClient interface {
	Send(*CheckQuery) error
	CloseAndRecv() (*CheckResponse, error)
	grpc.ClientStream
}

type FileInfoProvider_CheckServer 

type FileInfoProvider_CheckServer interface {
	SendAndClose(*CheckResponse) error
	Recv() (*CheckQuery, error)
	grpc.ServerStream
}

type GrpcFileinfo 

type GrpcFileinfo struct {
	Conn   *grpc.ClientConn
	Client FileInfoProviderClient
	// contains filtered or unexported fields
}

func NewGrpcFileinfo 

func NewGrpcFileinfo(conn *grpc.ClientConn) (*GrpcFileinfo, error)

func (*GrpcFileinfo) Check 

func (s *GrpcFileinfo) Check(filename string, reader io.Reader) ([]byte, error)

func (*GrpcFileinfo) Close 

func (s *GrpcFileinfo) Close() error

func (*GrpcFileinfo) MinimumBytes 

func (s *GrpcFileinfo) MinimumBytes(typ, subtyp string) (int64, error)

func (*GrpcFileinfo) Render 

func (s *GrpcFileinfo) Render(data []byte) (string, string, error)

type MinimumBytesQuery 

type MinimumBytesQuery struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Subtype string `protobuf:"bytes,2,opt,name=subtype,proto3" json:"subtype,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimumBytesQuery) Descriptor deprecated 

func (*MinimumBytesQuery) Descriptor() ([]byte, []int)

Deprecated: Use MinimumBytesQuery.ProtoReflect.Descriptor instead.

func (*MinimumBytesQuery) GetSubtype 

func (x *MinimumBytesQuery) GetSubtype() string

func (*MinimumBytesQuery) GetType 

func (x *MinimumBytesQuery) GetType() string

func (*MinimumBytesQuery) ProtoMessage 

func (*MinimumBytesQuery) ProtoMessage()

func (*MinimumBytesQuery) ProtoReflect 

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

func (*MinimumBytesQuery) Reset 

func (x *MinimumBytesQuery) Reset()

func (*MinimumBytesQuery) String 

func (x *MinimumBytesQuery) String() string

type MinimumBytesResponse 

type MinimumBytesResponse struct {
	Length int64  `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimumBytesResponse) Descriptor deprecated 

func (*MinimumBytesResponse) Descriptor() ([]byte, []int)

Deprecated: Use MinimumBytesResponse.ProtoReflect.Descriptor instead.

func (*MinimumBytesResponse) GetError 

func (x *MinimumBytesResponse) GetError() *Error

func (*MinimumBytesResponse) GetLength 

func (x *MinimumBytesResponse) GetLength() int64

func (*MinimumBytesResponse) ProtoMessage 

func (*MinimumBytesResponse) ProtoMessage()

func (*MinimumBytesResponse) ProtoReflect 

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

func (*MinimumBytesResponse) Reset 

func (x *MinimumBytesResponse) Reset()

func (*MinimumBytesResponse) String 

func (x *MinimumBytesResponse) String() string

type RenderQuery 

type RenderQuery struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RenderQuery) Descriptor deprecated 

func (*RenderQuery) Descriptor() ([]byte, []int)

Deprecated: Use RenderQuery.ProtoReflect.Descriptor instead.

func (*RenderQuery) GetData 

func (x *RenderQuery) GetData() []byte

func (*RenderQuery) ProtoMessage 

func (*RenderQuery) ProtoMessage()

func (*RenderQuery) ProtoReflect 

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

func (*RenderQuery) Reset 

func (x *RenderQuery) Reset()

func (*RenderQuery) String 

func (x *RenderQuery) String() string

type RenderResponse 

type RenderResponse struct {
	Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Title   string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Error   *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RenderResponse) Descriptor deprecated 

func (*RenderResponse) Descriptor() ([]byte, []int)

Deprecated: Use RenderResponse.ProtoReflect.Descriptor instead.

func (*RenderResponse) GetContent 

func (x *RenderResponse) GetContent() string

func (*RenderResponse) GetError 

func (x *RenderResponse) GetError() *Error

func (*RenderResponse) GetTitle 

func (x *RenderResponse) GetTitle() string

func (*RenderResponse) ProtoMessage 

func (*RenderResponse) ProtoMessage()

func (*RenderResponse) ProtoReflect 

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

func (*RenderResponse) Reset 

func (x *RenderResponse) Reset()

func (*RenderResponse) String 

func (x *RenderResponse) String() string

type UnimplementedFileInfoProviderServer 

type UnimplementedFileInfoProviderServer struct {
}

UnimplementedFileInfoProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedFileInfoProviderServer) Check 

func (UnimplementedFileInfoProviderServer) Check(FileInfoProvider_CheckServer) error

func (UnimplementedFileInfoProviderServer) MinimumBytes 

func (UnimplementedFileInfoProviderServer) MinimumBytes(context.Context, *MinimumBytesQuery) (*MinimumBytesResponse, error)

func (UnimplementedFileInfoProviderServer) Render 

func (UnimplementedFileInfoProviderServer) Render(context.Context, *RenderQuery) (*RenderResponse, error)

type UnsafeFileInfoProviderServer 

type UnsafeFileInfoProviderServer interface {
	// contains filtered or unexported methods
}

UnsafeFileInfoProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileInfoProviderServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.