monos

Documentation

Index

• Constants
• Variables
• type EupalinosClient
• type MelissosHandler
  • func CreateNewConfig(env string, duration time.Duration, finished int64) (*MelissosHandler, *grpc.ClientConn, error)
  • func (m *MelissosHandler) HandleDutch() bool
  • func (m *MelissosHandler) HandleParmenides() bool
  • func (m *MelissosHandler) PrintProgress()
  • func (m *MelissosHandler) WaitForJobsToFinish(c chan bool)
• 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 (
	EnvWaitTime     string = "WAIT_TIME"
	DefaultWaitTime string = "120"
)

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

Variables

var NumberOfDequeue int

Types

type EupalinosClient

type EupalinosClient interface {
	DequeueMessage(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.Epistello, error)
	GetQueueLength(ctx context.Context, in *pb.ChannelInfo, opts ...grpc.CallOption) (*pb.QueueLength, error)
}

type MelissosHandler

type MelissosHandler struct {
	Duration     time.Duration
	TimeFinished int64
	Index        string
	Created      int
	Updated      int
	Processed    int
	Elastic      elastic.Client
	Eupalinos    EupalinosClient
	Channel      string
	DutchChannel string
	WaitTime     time.Duration
	Kube         *thales.KubeClient
	Namespace    string
	Job          string
	Ambassador   *ptolemaios.ClientAmbassador
}

func CreateNewConfig

func CreateNewConfig(env string, duration time.Duration, finished int64) (*MelissosHandler, *grpc.ClientConn, error)

func (*MelissosHandler) HandleDutch

func (m *MelissosHandler) HandleDutch() bool

func (*MelissosHandler) HandleParmenides

func (m *MelissosHandler) HandleParmenides() bool

func (*MelissosHandler) PrintProgress

func (m *MelissosHandler) PrintProgress()

func (*MelissosHandler) WaitForJobsToFinish

func (m *MelissosHandler) WaitForJobsToFinish(c chan bool)

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