app

Documentation

Index

• Constants
• Variables
• type MelissosHandler
  • func (m *MelissosHandler) HandleDutch() bool
  • func (m *MelissosHandler) HandleParmenides() bool
  • func (m *MelissosHandler) PrintProgress()
• type MockEupalinosClient
  • func (m *MockEupalinosClient) DequeueMessage(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.Epistello, error)
  • func (m *MockEupalinosClient) GetQueueLength(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.QueueLength, error)

Constants

const (
	TestLength = "TEST_LENGTH"
	TestData   = "TEST_DATA"
)

Variables

var NumberOfDequeue int

Types

type MelissosHandler

type MelissosHandler struct {
	Config *configs.Config
}

func (*MelissosHandler) HandleDutch

func (m *MelissosHandler) HandleDutch() bool

func (*MelissosHandler) HandleParmenides

func (m *MelissosHandler) HandleParmenides() bool

func (*MelissosHandler) PrintProgress

func (m *MelissosHandler) PrintProgress()

type MockEupalinosClient

type MockEupalinosClient struct {
}

MockEupalinosClient is a mock implementation of EupalinosClient

func (*MockEupalinosClient) DequeueMessage

func (m *MockEupalinosClient) DequeueMessage(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.Epistello, error)

DequeueMessage is the mock implementation for the EnqueueMessage method

func (*MockEupalinosClient) GetQueueLength

func (m *MockEupalinosClient) GetQueueLength(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.QueueLength, error)

EnqueueMessage is the mock implementation for the EnqueueMessage method