test

Documentation

Index

• type ContentWriterMock
  • func NewContentWriterServerMock() *ContentWriterMock
  • func (s *ContentWriterMock) Close()
  • func (s *ContentWriterMock) Delete(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *ContentWriterMock) Flush(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *ContentWriterMock) Reset()
  • func (s *ContentWriterMock) Write(stream contentwriterV1.ContentWriter_WriteServer) error
• type LogServiceMock
  • func NewLogServiceMock() *LogServiceMock
  • func (s *LogServiceMock) Close()
  • func (s *LogServiceMock) Len() int
  • func (s *LogServiceMock) Reset()
  • func (s *LogServiceMock) WriteCrawlLog(stream logV1.Log_WriteCrawlLogServer) error

Types

type ContentWriterMock

type ContentWriterMock struct {
	contentwriterV1.UnimplementedContentWriterServer
	*grpc.Server

	Cancel  string
	Header  *contentwriterV1.Data
	Payload *contentwriterV1.Data
	Meta    *contentwriterV1.WriteRequestMeta
	// contains filtered or unexported fields
}

ContentWriterMock is used to implement ContentWriterServer.

func NewContentWriterServerMock

func NewContentWriterServerMock() *ContentWriterMock

NewContentWriterServerMock creates a new ContentWriterServerMock

func (*ContentWriterMock) Close

func (s *ContentWriterMock) Close()

Close implements ContentWriterServer

func (*ContentWriterMock) Delete

func (s *ContentWriterMock) Delete(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

Delete implements ContentWriterServer

func (*ContentWriterMock) Flush

func (s *ContentWriterMock) Flush(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

Flush implements ContentWriterServer

func (*ContentWriterMock) Reset

func (s *ContentWriterMock) Reset()

func (*ContentWriterMock) Write

func (s *ContentWriterMock) Write(stream contentwriterV1.ContentWriter_WriteServer) error

Write implements ContentWriterServer

type LogServiceMock

type LogServiceMock struct {
	logV1.UnimplementedLogServer
	*grpc.Server

	CrawlLog *logV1.CrawlLog
	// contains filtered or unexported fields
}

LogServiceMock is used to implement ContentWriterServer.

func NewLogServiceMock

func NewLogServiceMock() *LogServiceMock

NewContentWriterServerMock creates a new ContentWriterServerMock

func (*LogServiceMock) Close

func (s *LogServiceMock) Close()

Close implements ContentWriterServer

func (*LogServiceMock) Len

func (s *LogServiceMock) Len() int

func (*LogServiceMock) Reset

func (s *LogServiceMock) Reset()

func (*LogServiceMock) WriteCrawlLog

func (s *LogServiceMock) WriteCrawlLog(stream logV1.Log_WriteCrawlLogServer) error