serviceimplementation

Documentation

Index

• func ExecuteWorkerLocally(s DtaService, fileName string) string
• func Work(s *DtaService, input []byte, options *structpb.Struct) (string, []string, error)
• type DtaService
  • func (s *DtaService) GetDocTransServer() *pb.GenDocTransServer
  • func (s *DtaService) ListServices(ctx context.Context, req *empty.Empty) (*pb.ListServicesResponse, error)
  • func (*DtaService) Options(ctx context.Context, req *empty.Empty) (*pb.OptionsResponse, error)
  • func (s *DtaService) TransformDocument(ctx context.Context, in *pb.TransformDocumentRequest) (*pb.TransformDocumentResponse, error)
  • func (*DtaService) TransformDocumentPipe(context.Context, *pb.TransformDocumentPipeRequest) (*pb.TransformDocumentResponse, error)

Functions

func ExecuteWorkerLocally

func ExecuteWorkerLocally(s DtaService, fileName string) string

ExecuteWorkerLocally executes the worker locally, and returns the transformation result as string

func Work

func Work(s *DtaService, input []byte, options *structpb.Struct) (string, []string, error)

Work returns an encoded JSON object containing the bytes count the number of bytes lines count the numnber of lines words count the number of words The Service returns the number of lines, words, and bytes contained in the input document

Types

type DtaService

type DtaService struct {
	pb.IDocTransServer
	pb.GenDocTransServer
	pb.UnimplementedDTAServerServer
}

func (*DtaService) GetDocTransServer

func (s *DtaService) GetDocTransServer() *pb.GenDocTransServer

func (*DtaService) ListServices

func (s *DtaService) ListServices(ctx context.Context, req *empty.Empty) (*pb.ListServicesResponse, error)

func (*DtaService) Options

func (*DtaService) Options(ctx context.Context, req *empty.Empty) (*pb.OptionsResponse, error)

func (*DtaService) TransformDocument

func (s *DtaService) TransformDocument(ctx context.Context, in *pb.TransformDocumentRequest) (*pb.TransformDocumentResponse, error)

TransformDocument implements dtaservice.DTAServer

func (*DtaService) TransformDocumentPipe

func (*DtaService) TransformDocumentPipe(context.Context, *pb.TransformDocumentPipeRequest) (*pb.TransformDocumentResponse, error)