protoprocess

type APIClient ¶

type APIClient interface {
	Do(ctx context.Context, opts ...grpc.CallOption) (API_DoClient, error)
}

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer ¶

type APIServer interface {
	Do(API_DoServer) error
}

func NewAPIServer(processor Processor, server Server) APIServer

type API_DoClient ¶

type API_DoClient interface {
	Send(*google_protobuf.BytesValue) error
	Recv() (*google_protobuf.BytesValue, error)
	grpc.ClientStream
}

type API_DoServer ¶

type API_DoServer interface {
	Send(*google_protobuf.BytesValue) error
	Recv() (*google_protobuf.BytesValue, error)
	grpc.ServerStream
}

type Client ¶

type Client interface {
	Process(dirPath string, streamingBytesDuplexCloser protostream.StreamingBytesDuplexCloser) error
}

Client calls a remote Processor.

func NewClient(archiver pkgarchive.Archiver, opts ClientOptions) Client

type ClientOptions ¶

type ClientOptions struct {
	ChunkSizeBytes int
}

ClientOptions are options to the construction of a Client.

type Processor ¶

type Processor interface {
	Process(dirPath string) error
}

Processor processes the contents of a directory.

The result of a call to a Processor is that the directory may have modified contents.

func NewAPIProcessor(client Client, apiClient APIClient) Processor

type Server ¶

type Server interface {
	Handle(processor Processor, streamingBytesDuplexer protostream.StreamingBytesDuplexer) error
}

Server wraps a Processor.

func NewServer(archiver pkgarchive.Archiver, opts ServerOptions) Server

type ServerOptions ¶

type ServerOptions struct {
	ChunkSizeBytes int
}

ServerOptions are options to the construction of a Server.