ports

type Analyter interface {
	WriteEvent(ctx context.Context, msg *models.Message) error
	GetAggregates(ctx context.Context) (*models.Totals, []models.Delay, error)
}

type Auther interface {
	Authenticate(ctx context.Context, token *models.TokenPair) (*models.TokenPair, error)
}

type EventStorage interface {
	Insert(ctx context.Context, msg *models.Message) error
	Select(ctx context.Context, ID uint64) (*models.Message, error)
	Update(ctx context.Context, msg *models.Message) error
	UpdateDelay(ctx context.Context, msg *models.Message) error

	GetAggregates(ctx context.Context) (*models.Totals, []models.Delay, error)
}

type MsgListener interface {
	ProcessMessage(ctx context.Context, msg *models.Message) error
}

type MsgListener2 interface {
	WriteMessage(ctx context.Context, r *pb.WriteMessageRequest) (*empty.Empty, error)
}